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

Added flows to light rrd update (#6029)

Browse source
This commit is contained in:
MatteoBiscosi 2021-11-02 11:58:24 +01:00
parent 8bcf3509c0
commit 225c074f80
1 changed files with 35 additions and 32 deletions
Download patch file Download diff file Expand all files Collapse all files

67
scripts/lua/modules/ts_5min_dump_utils.lua
View file

@ -438,20 +438,6 @@ end
-- ########################################################
function ts_dump.host_update_stats_rrds(when, hostname, host, ifstats, verbose)
-- Number of flows
if(host["active_flows.as_client"]) then
ts_utils.append("host:active_flows", {ifid=ifstats.id, host=hostname,
flows_as_client = host["active_flows.as_client"],
flows_as_server = host["active_flows.as_server"]},
when)
end
ts_utils.append("host:total_flows", {ifid=ifstats.id, host=hostname,
flows_as_client = host["total_flows.as_client"],
flows_as_server = host["total_flows.as_server"]},
when)
-- Number of alerted flows
ts_utils.append("host:alerted_flows", {ifid = ifstats.id, host = hostname,
flows_as_client = host["alerted_flows.as_client"],
@ -703,6 +689,40 @@ function ts_dump.host_update_categories_rrds(when, hostname, host, ifstats, verb
end
end
function ts_dump.host_update_categories_rrds(when, hostname, host, ifstats, verbose)
-- Traffic stats
ts_utils.append("host:traffic", {ifid=ifstats.id, host=hostname,
bytes_sent=host["bytes.sent"], bytes_rcvd=host["bytes.rcvd"]}, when)
-- Score
ts_utils.append("host:score", {ifid=ifstats.id, host=hostname, score_as_cli = host["score.as_client"], score_as_srv = host["score.as_server"]}, when)
-- Total number of alerts
ts_utils.append("host:total_alerts", {ifid = ifstats.id, host = hostname,
alerts = host["total_alerts"]},
when)
-- Engaged alerts
if host["engaged_alerts"] then
ts_utils.append("host:engaged_alerts", {ifid = ifstats.id, host = hostname,
alerts = host["engaged_alerts"]},
when)
end
-- Number of flows
if(host["active_flows.as_client"] or host["active_flows.as_server"]) then
ts_utils.append("host:active_flows", {ifid=ifstats.id, host=hostname,
flows_as_client = host["active_flows.as_client"] or 0,
flows_as_server = host["active_flows.as_server"] or 0},
when)
end
ts_utils.append("host:total_flows", {ifid=ifstats.id, host=hostname,
flows_as_client = host["total_flows.as_client"],
flows_as_server = host["total_flows.as_server"]},
when)
end
-- ########################################################
function ts_dump.host_update_rrd(when, hostname, host, ifstats, verbose, config)
@ -714,24 +734,7 @@ function ts_dump.host_update_rrd(when, hostname, host, ifstats, verbose, config)
------ Light stats ------
-- Traffic stats
ts_utils.append("host:traffic", {ifid=ifstats.id, host=hostname,
bytes_sent=host["bytes.sent"], bytes_rcvd=host["bytes.rcvd"]}, when)
-- Score
ts_utils.append("host:score", {ifid=ifstats.id, host=hostname, score_as_cli = host["score.as_client"], score_as_srv = host["score.as_server"]}, when)
-- Total number of alerts
ts_utils.append("host:total_alerts", {ifid = ifstats.id, host = hostname,
alerts = host["total_alerts"]},
when)
-- Engaged alerts
if host["engaged_alerts"] then
ts_utils.append("host:engaged_alerts", {ifid = ifstats.id, host = hostname,
alerts = host["engaged_alerts"]},
when)
end
ts_dump.light_host_update_rrd(when, hostname, host, ifstats, verbose)
------------------------