wehub-resource-sync
59 lines
1.5 KiB
Lua
59 lines
1.5 KiB
Lua
local log = require "kong.cmd.utils.log"
|
|
local kill = require "kong.cmd.utils.kill"
|
|
local pl_path = require "pl.path"
|
|
local pl_tablex = require "pl.tablex"
|
|
local conf_loader = require "kong.conf_loader"
|
|
|
|
local ljust = require("pl.stringx").ljust
|
|
|
|
local function execute(args)
|
|
log.disable()
|
|
-- retrieve default prefix or use given one
|
|
local default_conf = assert(conf_loader(nil, {
|
|
prefix = args.prefix
|
|
}))
|
|
log.enable()
|
|
assert(pl_path.exists(default_conf.prefix),
|
|
"no such prefix: " .. default_conf.prefix)
|
|
assert(pl_path.exists(default_conf.kong_env),
|
|
"Kong is not running at " .. default_conf.prefix)
|
|
|
|
-- load <PREFIX>/kong.conf containing running node's config
|
|
local conf = assert(conf_loader(default_conf.kong_env))
|
|
|
|
local pids = {
|
|
nginx = conf.nginx_pid,
|
|
}
|
|
|
|
local count = 0
|
|
for k, v in pairs(pids) do
|
|
local running = kill.is_running(v)
|
|
local msg = ljust(k, 12, ".") .. (running and "running" or "not running")
|
|
if running then
|
|
count = count + 1
|
|
end
|
|
log(msg)
|
|
end
|
|
|
|
log("") -- line jump
|
|
|
|
assert(count > 0, "Kong is not running at " .. conf.prefix)
|
|
assert(count == pl_tablex.size(pids), "some services are not running at " .. conf.prefix)
|
|
|
|
log("Kong is healthy at %s", conf.prefix)
|
|
end
|
|
|
|
local lapp = [[
|
|
Usage: kong health [OPTIONS]
|
|
|
|
Check if the necessary services are running for this node.
|
|
|
|
Options:
|
|
-p,--prefix (optional string) prefix at which Kong should be running
|
|
]]
|
|
|
|
return {
|
|
lapp = lapp,
|
|
execute = execute
|
|
}
|