Versions in this module Expand all Collapse all v1 v1.6.7 Feb 27, 2018 Changes in this version + func LoadStatisticalMethod(j string) map[string]*StatisticalMethod + func NewServerSession(Id string, Stype string, Rpc mqrpc.RPCClient) module.ServerSession + type BaseModule struct + App module.App + func (m *BaseModule) BeforeHandle(fn string, session gate.Session, 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, hash string) (s module.ServerSession, err error) + func (m *BaseModule) GetServer() *rpcserver + func (m *BaseModule) GetServerId() string + func (m *BaseModule) GetStatistical() (statistical string, err error) + func (m *BaseModule) GetSubclass() module.RPCModule + 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) 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) + func (mer *ModuleManager) ReportStatistics(args interface{}) + type StatisticalMethod struct + EndTime int64 + ExecFailure int + ExecSuccess int + ExecTimeout int + ExecTotal int + MaxExecTime int64 + MinExecTime int64 + Name string + StartTime int64