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

Adds InfluxDB total exports

Browse source
This commit is contained in:
Simone Mainardi 2019-06-25 18:23:58 +02:00
parent 221b224abb
commit 775b6f8842
5 changed files with 35 additions and 34 deletions
Download patch file Download diff file Expand all files Collapse all files

19
scripts/lua/modules/timeseries/drivers/influxdb.lua
View file

@ -704,6 +704,12 @@ end
-- ##############################################
local function get_exports_key(ifid)
return string.format(INFLUX_KEY_PREFIX.."exports", ifid)
end
-- ##############################################
local function inc_val(k, val_to_add)
local val = tonumber(ntop.getCache(k)) or 0
@ -725,6 +731,12 @@ end
-- ##############################################
function inc_exports(ifid)
inc_val(get_exports_key(ifid), 1)
end
-- ##############################################
function driver:get_dropped_points(ifid)
return tonumber(ntop.getCache(get_dropped_points_key(ifid))) or 0
end
@ -737,6 +749,12 @@ end
-- ##############################################
function driver:get_exports(ifid)
return tonumber(ntop.getCache(get_exports_key(ifid))) or 0
end
-- ##############################################
local function deleteExportableFile(exportable)
if exportable and exportable["fname"] then
if ntop.exists(exportable["fname"]) then
@ -761,6 +779,7 @@ local function exportableSuccess(exportable)
interface.select(exportable["ifid_str"])
inc_exported_points(exportable["ifid"], exportable["num_points"])
inc_exports(exportable["ifid"])
deleteExportableFile(exportable)
end