function _M.loop_load()
local loop_handler
function loop_handler(premature)
ngx_log(ngx_err, "Timer prematurely expired: ", premature)
ngx_log(ngx_err, "Worker exiting: ", ngx.worker.exiting())
if not premature then
if _M.sync_consul() then
local ok, err = timer_at(delay, loop_handler)
if not ok then
ngx_log(ngx_err, "Call timer_at failed: ", err)
return
end
ngx_log(ngx_err, "Looping in timer!")
end
else
global_set:set("looped", false)
end
end
if global_set:get("looped") == false then
if 0 == ngx.worker.id() then
local ok, err = timer_at(delay, loop_handler)
if not ok then
ngx_log(ngx_err, "Call timer_at failed: ", err)
return
end
global_set:set("looped", true)
ngx_log(ngx_err, "Starting loop load consul data!")
end
end
end
