Versions in this module Expand all Collapse all v1 v1.2.1 Mar 15, 2020 Changes in this version + func LoadStatisticalMethod(j string) map[string]*StatisticalMethod + func NewServerSession(app module.App, name string, node *registry.Node) (module.ServerSession, error) + type BaseModule struct + App module.App + func (m *BaseModule) BeforeHandle(fn string, callInfo *mqrpc.CallInfo) error + func (m *BaseModule) GetApp() module.App + func (m *BaseModule) GetExecuting() int64 + func (m *BaseModule) GetModuleSettings() *conf.ModuleSettings + func (m *BaseModule) GetRouteServer(moduleType string, opts ...selector.SelectOption) (s module.ServerSession, err error) + func (m *BaseModule) GetServer() server.Server + func (m *BaseModule) GetServerId() string + func (m *BaseModule) GetStatistical() (statistical string, err error) + func (m *BaseModule) GetSubclass() module.RPCModule + func (m *BaseModule) NoFoundFunction(fn string) (*mqrpc.FunctionInfo, error) + func (m *BaseModule) OnAppConfigurationLoaded(app module.App) + func (m *BaseModule) OnComplete(fn string, callInfo *mqrpc.CallInfo, result *rpcpb.ResultInfo, exec_time int64) + func (m *BaseModule) OnConfChanged(settings *conf.ModuleSettings) + func (m *BaseModule) OnDestroy() + func (m *BaseModule) OnError(fn string, callInfo *mqrpc.CallInfo, err error) + func (m *BaseModule) OnInit(subclass module.RPCModule, app module.App, settings *conf.ModuleSettings, ...) + func (m *BaseModule) OnTimeOut(fn string, Expired int64) + func (m *BaseModule) RpcCall(ctx context.Context, moduleType, _func string, param mqrpc.ParamOption, ...) (interface{}, string) + func (m *BaseModule) RpcInvoke(moduleType string, _func string, params ...interface{}) (result interface{}, err string) + func (m *BaseModule) RpcInvokeArgs(moduleType string, _func string, ArgsType []string, args [][]byte) (result interface{}, err string) + func (m *BaseModule) RpcInvokeNR(moduleType string, _func string, params ...interface{}) (err error) + func (m *BaseModule) RpcInvokeNRArgs(moduleType string, _func string, ArgsType []string, args [][]byte) (err error) + func (m *BaseModule) SetListener(listener mqrpc.RPCListener) + type DefaultModule struct + type ModuleManager struct + func NewModuleManager() (m *ModuleManager) + func (mer *ModuleManager) CheckModuleSettings() + func (mer *ModuleManager) Destroy() + func (mer *ModuleManager) Init(app module.App, ProcessID string) + func (mer *ModuleManager) Register(mi module.Module) + func (mer *ModuleManager) RegisterRunMod(mi module.Module) + type StatisticalMethod struct + EndTime int64 + ExecFailure int + ExecSuccess int + ExecTimeout int + ExecTotal int + MaxExecTime int64 + MinExecTime int64 + Name string + StartTime int64