...
|
...
|
@@ -5,45 +5,45 @@ local get_servers = upstream.get_servers |
|
|
local get_upstreams = upstream.get_upstreams
|
|
|
local cache=ngx.shared.upstream
|
|
|
|
|
|
|
|
|
function list()
|
|
|
local t={}
|
|
|
local us=get_upstreams()
|
|
|
-- get all peers for upstram: u
|
|
|
function list(u)
|
|
|
|
|
|
for _,u in ipairs(us) do
|
|
|
local peers,err = upstream.get_primary_peers(u)
|
|
|
if err then
|
|
|
ngx.say("failed to get servers in upstream ", u)
|
|
|
local d={}
|
|
|
d["name"]=u
|
|
|
d["value"]={}
|
|
|
|
|
|
-- get primary peers
|
|
|
local peers,err = upstream.get_primary_peers(u)
|
|
|
if err then
|
|
|
ngx.say("failed to get primary servers in upstream ", u)
|
|
|
return
|
|
|
end
|
|
|
local d={}
|
|
|
d["name"]=u
|
|
|
d["value"]={}
|
|
|
for _,p in ipairs(peers) do
|
|
|
end
|
|
|
for _,p in ipairs(peers) do
|
|
|
local s={}
|
|
|
s["id"]=p.id
|
|
|
s["down"]=p.down and p.down or false
|
|
|
s["name"]=p.name
|
|
|
s["backup"]=false
|
|
|
table.insert(d["value"],s)
|
|
|
end
|
|
|
peers,err = upstream.get_backup_peers(u)
|
|
|
if err then
|
|
|
ngx.say("failed to get servers in upstream ", u)
|
|
|
end
|
|
|
|
|
|
-- get backup peers
|
|
|
peers,err = upstream.get_backup_peers(u)
|
|
|
if err then
|
|
|
ngx.say("failed to get backup servers in upstream ", u)
|
|
|
return
|
|
|
end
|
|
|
for _,p in ipairs(peers) do
|
|
|
end
|
|
|
for _,p in ipairs(peers) do
|
|
|
local s={}
|
|
|
s["id"]=p.id
|
|
|
s["down"]=p.down and p.down or false
|
|
|
s["name"]=p.name
|
|
|
s["backup"]=true
|
|
|
table.insert(d["value"],s)
|
|
|
end
|
|
|
table.insert(t,d)
|
|
|
end
|
|
|
end
|
|
|
|
|
|
ngx.header["Content-type"]="application/json;charset=utf-8"
|
|
|
ngx.say(json.encode(t))
|
|
|
ngx.say(json.encode(d))
|
|
|
end
|
|
|
|
|
|
|
...
|
...
|
@@ -68,7 +68,8 @@ end |
|
|
local args=ngx.req.get_uri_args()
|
|
|
local method=args["method"]
|
|
|
if method == "list" then
|
|
|
list()
|
|
|
local u_name = args["upstream"]
|
|
|
list(u_name)
|
|
|
elseif(method=="down" or method=="up") then
|
|
|
local upstream=args["upstream"]
|
|
|
local backup=args["backup"]=="true" and true or false
|
...
|
...
|
|