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

Implements Observation Point Timeseries (#5644)

Browse source
This commit is contained in:
MatteoBiscosi 2021-07-07 12:43:43 +02:00
parent adc1575a41
commit 09c33731d0
8 changed files with 54 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

15
scripts/lua/modules/ts_min_dump_utils.lua
View file

@ -183,6 +183,15 @@ function ts_dump.profiles_update_stats(when, ifstats, verbose)
end
end
function ts_dump.observation_points_update_stats_rrds(when, ifstats, verbose)
local observation_points = interface.getObservationPoints() or {}
for id, stats in pairs(observation_points) do
ts_utils.append("observation_point:flows", {ifid=ifstats.id, observation_point_id=id, flows=stats["num_collected_flows"]}, when)
ts_utils.append("observation_point:traffic", {ifid=ifstats.id, observation_point_id=id, bytes=stats["total_flow_bytes"]}, when)
end
end
-- ########################################################
local function update_internals_hash_tables_stats(when, ifstats, verbose)
@ -400,6 +409,10 @@ function ts_dump.run_min_dump(_ifname, ifstats, config, when)
ts_dump.update_internals_periodic_activities_stats(when, ifstats, verbose)
end
if ntop.isPro() and config.observation_points_rrd_creation ~= "0" then
ts_dump.observation_points_update_stats_rrds(when, ifstats, verbose)
end
-- Save Profile stats every minute
if ntop.isPro() and ifstats.profiles then -- profiles are only available in the Pro version
ts_dump.profiles_update_stats(when, ifstats, verbose)
@ -428,11 +441,13 @@ function ts_dump.getConfig()
config.interface_ndpi_timeseries_creation = ntop.getPref("ntopng.prefs.interface_ndpi_timeseries_creation")
config.ndpi_flows_timeseries_creation = ntop.getPref("ntopng.prefs.ndpi_flows_rrd_creation")
config.observation_points_rrd_creation = ntop.getPref("ntopng.prefs.observation_points_rrd_creation")
config.internals_rrd_creation = ntop.getPref("ntopng.prefs.internals_rrd_creation") == "1"
config.is_dump_flows_enabled = ntop.getPrefs()["is_dump_flows_enabled"]
-- Interface RRD creation is on, with per-protocol nDPI
if isEmptyString(config.interface_ndpi_timeseries_creation) then config.interface_ndpi_timeseries_creation = "per_protocol" end
if isEmptyString(config.observation_points_rrd_creation) then config.observation_points_rrd_creation = "0" end
return config
end