Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IClusterService ¶
type IClusterService interface { core.IService GetTag() string //集群服务器标签 GetCategory() core.S_Category //服务类别 GetRpcId() string //集群服务Rpc通信id GetPreWeight() int32 //集群服务负载值 GetSessionsByCategory(category core.S_Category) (ss []core.IServiceSession) //获取服务会话 DefauleRpcRouteRules(stype string) (ss core.IServiceSession, err error) //集群服务默认rpc路由规则 RpcInvokeById(sId string, rkey core.Rpc_Key, iscall bool, arg ...interface{}) (result interface{}, err error) //执行远程服务Rpc方法 RpcInvokeByType(sType string, rkey core.Rpc_Key, iscall bool, arg ...interface{}) (result interface{}, err error) //根据路由规则执行远程方法 ReleaseRpc(rkey core.Rpc_Key, arg ...interface{}) //发布Rpc Register(id core.Rpc_Key, f interface{}) (err error) //注册RPC远程方法 RegisterGO(id core.Rpc_Key, f interface{}) (err error) //注册RPC远程方法 Subscribe(id core.Rpc_Key, f interface{}) (err error) //订阅Rpc UnSubscribe(id core.Rpc_Key, f interface{}) (err error) //订阅Rpc }
type ISingleService ¶
Click to show internal directories.
Click to hide internal directories.