wehub-resource-sync
31 lines
749 B
Lua
31 lines
749 B
Lua
local policies = require "kong.plugins.response-ratelimiting.policies"
|
|
local pairs = pairs
|
|
|
|
|
|
local _M = {}
|
|
|
|
|
|
local function log(premature, conf, identifier, current_timestamp, increments, usage)
|
|
if premature then
|
|
return
|
|
end
|
|
|
|
-- Increment metrics for all periods if the request goes through
|
|
for k in pairs(usage) do
|
|
if increments[k] and increments[k] ~= 0 then
|
|
policies[conf.policy].increment(conf, identifier, k, current_timestamp, increments[k])
|
|
end
|
|
end
|
|
end
|
|
|
|
|
|
function _M.execute(conf, identifier, current_timestamp, increments, usage)
|
|
local ok, err = ngx.timer.at(0, log, conf, identifier, current_timestamp, increments, usage)
|
|
if not ok then
|
|
kong.log.err("failed to create timer: ", err)
|
|
end
|
|
end
|
|
|
|
|
|
return _M
|