Versions in this module Expand all Collapse all v1 v1.3.0 Apr 17, 2024 Changes in this version + type ClusterService struct + ClusterService base.IClusterService + IsInClustered bool + ServiceMonitor core.IServiceMonitor + func (this *ClusterService) Configure(opts ...Option) + func (this *ClusterService) DefauleRpcRouteRules(stype string, sip string) (ss core.IServiceSession, err error) + func (this *ClusterService) Destroy() (err error) + func (this *ClusterService) FindServiceHandlefunc(node registry.ServiceNode) + func (this *ClusterService) GetCategory() core.S_Category + func (this *ClusterService) GetId() string + func (this *ClusterService) GetIp() string + func (this *ClusterService) GetPreWeight() float64 + func (this *ClusterService) GetRpcId() string + func (this *ClusterService) GetServiceMonitor() core.IServiceMonitor + func (this *ClusterService) GetSessionsByCategory(category core.S_Category) (ss []core.IServiceSession) + func (this *ClusterService) GetSettings() core.ServiceSttings + func (this *ClusterService) GetTag() string + func (this *ClusterService) GetType() string + func (this *ClusterService) GetVersion() string + func (this *ClusterService) Init(service core.IService) (err error) + func (this *ClusterService) InitSys() + func (this *ClusterService) LoseServiceHandlefunc(sId string) + func (this *ClusterService) Options() *Options + func (this *ClusterService) Register(id core.Rpc_Key, f interface{}) + func (this *ClusterService) RegisterGO(id core.Rpc_Key, f interface{}) + func (this *ClusterService) ReleaseRpc(rkey core.Rpc_Key, arg ...interface{}) + func (this *ClusterService) RpcInvokeById(sId string, rkey core.Rpc_Key, iscall bool, arg ...interface{}) (result interface{}, err error) + func (this *ClusterService) RpcInvokeByIds(sId []string, rkey core.Rpc_Key, iscall bool, arg ...interface{}) (results map[string]*base.Result, err error) + func (this *ClusterService) RpcInvokeByIp(sIp, sType string, rkey core.Rpc_Key, iscall bool, arg ...interface{}) (result interface{}, err error) + func (this *ClusterService) RpcInvokeByIps(sIp []string, sType string, rkey core.Rpc_Key, iscall bool, arg ...interface{}) (results map[string]*base.Result, err error) + func (this *ClusterService) RpcInvokeByType(sType string, rkey core.Rpc_Key, iscall bool, arg ...interface{}) (result interface{}, err error) + func (this *ClusterService) Run(mod ...core.IModule) + func (this *ClusterService) SetPreWeight(weight int32) + func (this *ClusterService) Start() (err error) + func (this *ClusterService) Subscribe(id core.Rpc_Key, f interface{}) (err error) + func (this *ClusterService) UnSubscribe(id core.Rpc_Key, f interface{}) (err error) + func (this *ClusterService) UpDataServiceHandlefunc(node registry.ServiceNode) + type Option func(*Options) + func SetConfPath(v string) Option + func SetVersion(v string) Option + type Options struct + ConfPath string + Setting core.ServiceSttings + Version string
Go to main page