mirror of
https://github.com/cloudwu/skynet.git
synced 2026-07-25 12:43:09 +00:00
snax service support cluster
This commit is contained in:
@@ -24,6 +24,15 @@ function cluster.proxy(node, name)
|
||||
return skynet.call(clusterd, "lua", "proxy", node, name)
|
||||
end
|
||||
|
||||
function cluster.snax(node, name, address)
|
||||
local snax = require "snax"
|
||||
if not address then
|
||||
address = cluster.call(node, ".service", "QUERY", "snaxd" , name)
|
||||
end
|
||||
local handle = skynet.call(clusterd, "lua", "proxy", node, address)
|
||||
return snax.bind(handle, name)
|
||||
end
|
||||
|
||||
skynet.init(function()
|
||||
clusterd = skynet.uniqueservice("clusterd")
|
||||
end)
|
||||
|
||||
@@ -64,7 +64,7 @@ return function (name , G, loader)
|
||||
local pattern
|
||||
|
||||
do
|
||||
local path = skynet.getenv "snax"
|
||||
local path = assert(skynet.getenv "snax" , "please set snax in config file")
|
||||
|
||||
local errlist = {}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user