vrr/ntopng
2
0
Fork 0
mirror of https://github.com/ntop/ntopng.git synced 2026-05-01 00:19:33 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

Optimize timeseries schemas

Browse source
This commit is contained in:
emanuele-f 2018-06-01 11:16:57 +02:00
parent 2f89d21b36
commit 8c104817a1
10 changed files with 452 additions and 531 deletions
Download patch file Download diff file Expand all files Collapse all files

8
scripts/lua/modules/host_pools_utils.lua
View file

@ -466,24 +466,24 @@ end
function host_pools_utils.updateRRDs(ifid, dump_ndpi, verbose)
local ts_utils = require "ts_utils"
local ts_schemas = require "ts_schemas"
local ts_schemas = require "ts_5min"
-- NOTE: requires graph_utils
for pool_id, pool_stats in pairs(interface.getHostPoolsStats() or {}) do
ts_utils.append(ts_schemas.host_pool_traffic(), {ifid=ifid, pool=pool_id,
ts_utils.append(ts_schemas.host_pool_traffic, {ifid=ifid, pool=pool_id,
bytes_sent=pool_stats["bytes.sent"], bytes_rcvd=pool_stats["bytes.rcvd"]}, when)
if pool_id ~= tonumber(host_pools_utils.DEFAULT_POOL_ID) then
local flows_dropped = pool_stats["flows.dropped"] or 0
ts_utils.append(ts_schemas.host_pool_blocked_flows(), {ifid=ifid, pool=pool_id,
ts_utils.append(ts_schemas.host_pool_blocked_flows, {ifid=ifid, pool=pool_id,
num_flows=flows_dropped}, when)
end
-- nDPI stats
if dump_ndpi then
for proto,v in pairs(pool_stats["ndpi"] or {}) do
ts_utils.append(ts_schemas.host_pool_ndpi(), {ifid=ifid, pool=pool_id, protocol=proto,
ts_utils.append(ts_schemas.host_pool_ndpi, {ifid=ifid, pool=pool_id, protocol=proto,
bytes_sent=pool_stats["bytes.sent"], bytes_rcvd=pool_stats["bytes.rcvd"]}, when)
end
end