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

Added timeout support to postHTTPJsonData, ntop.postHTTPJsonData now accepts an optional timeout arg, added webhook timeout check

Browse source
This commit is contained in:
Alfredo Cardigliano 2019-01-07 23:36:39 +01:00
parent cb05c8ffed
commit 98adc8a79f
6 changed files with 39 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

12
scripts/lua/modules/alert_endpoints/webhook.lua
View file

@ -9,6 +9,8 @@ local webhook = {}
webhook.EXPORT_FREQUENCY = 60
webhook.API_VERSION = "0.1"
webhook.REQUEST_TIMEOUT = 1
webhook.ITERATION_TIMEOUT = 3
local MAX_ALERTS_PER_REQUEST = 10
function webhook.sendMessage(alerts)
@ -29,13 +31,21 @@ function webhook.sendMessage(alerts)
local json_message = json.encode(message)
return ntop.postHTTPJsonData(username, password, url, json_message)
return ntop.postHTTPJsonData(username, password, url, json_message, webhook.REQUEST_TIMEOUT)
end
function webhook.dequeueAlerts(queue)
local start_time = os.time()
local alerts = {}
while true do
local diff = os.time() - start_time
if diff >= webhook.ITERATION_TIMEOUT then
break
end
local json_alert = ntop.lpopCache(queue)
if not json_alert then