controller.lua

local dyna_controller = require "resty.dynacode.controller"
local controller = {}

local ok, setup_err = dyna_controller.setup({
  plugin_api_uri = "http://admin:3000/plugins/index.json",
  plugin_api_polling_interval = 15,
  plugin_api_poll_at_init = true,
  workers_max_jitter = 5,
  shm = "cache_dict",
})

if not ok then
  ngx.log(ngx.ERR, string.format("error during the setup err=%s", setup_err))
end

function controller.logger(msg)
  ngx.log(ngx.ERR, string.format("[controller worker_pid=%d phase=%s] %s", ngx.worker.pid(), ngx.get_phase(), msg))
end

dyna_controller.events.on(dyna_controller.events.BG_CACHE_HIT, function()
  controller.logger("cache hit")
end)

dyna_controller.events.on(dyna_controller.events.BG_CACHE_MISS, function()
  controller.logger("cache miss")
end)

dyna_controller.events.on(dyna_controller.events.BG_FETCH_API_SUCCESS, function()
  controller.logger("api success")
end)

dyna_controller.events.on(dyna_controller.events.BG_FETCH_API_STATUS_CODE_ERROR, function(status_code)
  controller.logger(string.format("api <> 200 status=%d", status_code))
end)

dyna_controller.events.on(dyna_controller.events.BG_FETCH_API_GENERIC_ERROR, function(err)
  controller.logger(string.format("api err=%s", err))
end)

dyna_controller.events.on(dyna_controller.events.BG_COMPILE_SUCCESS, function(plugin)
  controller.logger(string.format("compile success %s", plugin.name))
end)

dyna_controller.events.on(dyna_controller.events.BG_COMPILE_ERROR, function(plugin, err)
  controller.logger(string.format("compile error %s err=%s", plugin.name, err))
end)

dyna_controller.events.on(dyna_controller.events.BG_UPDATED_PLUGINS, function()
  controller.logger("updated plugins with success")
end)

dyna_controller.events.on(dyna_controller.events.BG_DIDNT_UPDATE_PLUGINS, function()
  controller.logger("didnt updated plugins with success")
end)

dyna_controller.events.on(dyna_controller.events.RT_PLUGINS_STARTING, function(plugin)
  controller.logger(string.format("about to run %s", plugin.name))
end)

dyna_controller.events.on(dyna_controller.events.RT_PLUGINS_DONE, function(plugin)
  controller.logger(string.format("done running %s", plugin.name))
end)

dyna_controller.events.on(dyna_controller.events.RT_PLUGINS_ERROR, function(plugin, err)
  controller.logger(string.format("error while running %s err=%s", plugin.name, err))
end)

dyna_controller.events.on(dyna_controller.events.ON_ERROR, function(section, err)
  controller.logger(string.format("error at %s err=%s", section, err))
end)

local metrics_ngx_shared = ngx.shared.metrics_dict
local events = {
  dyna_controller.events.BG_CACHE_HIT,
  dyna_controller.events.BG_CACHE_MISS,
  dyna_controller.events.BG_FETCH_API_SUCCESS,
  dyna_controller.events.BG_FETCH_API_STATUS_CODE_ERROR,
  dyna_controller.events.BG_FETCH_API_GENERIC_ERROR,
  dyna_controller.events.BG_COMPILE_ERROR,
  dyna_controller.events.BG_COMPILE_SUCCESS,
  dyna_controller.events.BG_UPDATED_PLUGINS,
  dyna_controller.events.BG_DIDNT_UPDATE_PLUGINS,
  dyna_controller.events.RT_PLUGINS_STARTING,
  dyna_controller.events.RT_PLUGINS_DONE,
  dyna_controller.events.RT_PLUGINS_ERROR,
  dyna_controller.events.ON_ERROR,
}

for _, event in ipairs(events) do
  dyna_controller.events.on(event, function()
    metrics_ngx_shared:incr(event, 1, 0)
  end)
end

function controller.render_metrics()
  local results = {}
  for _, event in ipairs(events) do
    local val = metrics_ngx_shared:get(event)
    results[event] = val
  end

  ngx.say(require("cjson").encode(results))
end

function controller.run()
  dyna_controller.run()
end

return controller