vrr/ntopng
2
0
Fork 0
mirror of https://github.com/ntop/ntopng.git synced 2026-04-30 16:09:32 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

Implement InfluxDB export statistics

Browse source
This commit is contained in:
emanuele-f 2019-06-10 15:50:44 +02:00
parent 3a6f121e11
commit cfa9986671
10 changed files with 206 additions and 24 deletions
Download patch file Download diff file Expand all files Collapse all files

26
scripts/lua/modules/system_scripts_utils.lua
View file

@ -62,8 +62,29 @@ end
-- ##############################################
function system_scripts.getSystemProbe(probe_name)
for task in system_scripts.getTasks() do
for name, probe in system_scripts.getSystemProbes(task) do
if name == probe_name then
return(probe)
end
end
end
-- Not Found
return(nil)
end
-- ##############################################
local tasks_cached = nil
function system_scripts.getTasks()
local tasks = pairsByKeys(ntop.readdir(system_scripts_dir))
if(tasks_cached == nil) then
tasks_cached = ntop.readdir(system_scripts_dir)
end
local tasks = pairsByKeys(tasks_cached)
return function()
local get_next = true
@ -108,6 +129,8 @@ function system_scripts.runTask(task, when)
end
for _, probe in system_scripts.getSystemProbes(task) do
interface.select(getSystemInterfaceId())
if(probe.runTask ~= nil) then
if(probe.loadSchemas ~= nil) then
-- Possibly load the schemas first
@ -120,6 +143,7 @@ function system_scripts.runTask(task, when)
-- Restore original function
ts_utils.newSchema = old_new_schema_fn
interface.select(getSystemInterfaceId())
return(true)
end