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

Move nindex specific code to pro

Browse source
This commit is contained in:
emanuele-f 2018-12-13 11:27:03 +01:00
parent 4504f40fbf
commit 7b67279a0f
1 changed files with 3 additions and 22 deletions
Download patch file Download diff file Expand all files Collapse all files

25
scripts/lua/modules/delete_data_utils.lua
View file

@ -302,8 +302,7 @@ end
-- ################################################################
-- no need to make it global yet
local function list_all_interfaces()
function delete_data_utils.list_all_interfaces()
return list_interfaces(false --[[ all interfaces, active and inactive --]])
end
@ -358,7 +357,7 @@ function delete_data_utils.delete_all_interfaces_data()
return
end
local if_list = list_all_interfaces()
local if_list = delete_data_utils.list_all_interfaces()
return delete_interfaces_from_list(if_list)
end
@ -442,7 +441,7 @@ end
-- ################################################################
-- NOTE: this has 1 day accuracy
local function harvestDateBasedDirTree(dir, retention, now)
function delete_data_utils.harvestDateBasedDirTree(dir, retention, now)
for year in pairs(ntop.readdir(dir) or {}) do
local year_path = os_utils.fixPath(dir .. "/" .. year)
local num_deleted_months = 0
@ -485,24 +484,6 @@ end
-- ################################################################
function delete_data_utils.delete_old_nindex_flows()
if ntop.isEnterprise() and hasNindexSupport() then
local nindex_utils = require "nindex_utils"
local retention = tonumber(ntop.getPref("ntopng.prefs.nindex_retention_days")) or 365
local if_list = list_all_interfaces()
for ifid in pairs(if_list) do
local now = os.time()
local flows_dirs = nindex_utils.getDirs(ifid)
harvestDateBasedDirTree(flows_dirs.flows, retention, now)
harvestDateBasedDirTree(flows_dirs.aggregatedflows, retention, now)
end
end
end
-- ################################################################
-- TRACKER HOOK
tracker.track(delete_data_utils, 'delete_all_interfaces_data')