module_util

func (mu *ModuleUtil) AddRPCSerialize(name string, Interface module.RPCSerialize) error

func (mu *ModuleUtil) Configure(settings CommonConf.Config) error

func (mu *ModuleUtil) GetModuleInit() func(app module.App, module module.Module)

func (mu *ModuleUtil) GetRPCSerialize() map[string]module.RPCSerialize

func (mu *ModuleUtil) GetRandomServerByType(typeName string) (module.ServerSession, error)

func (mu *ModuleUtil) GetServerByID(id string) (module.ServerSession, error)

func (mu *ModuleUtil) GetServersByType(typeName string) ([]module.ServerSession, error)

func (mu *ModuleUtil) GetServiceList() ([]module.ServerSession, error)

func (mu *ModuleUtil) GetSettings() CommonConf.Config

func (mu *ModuleUtil) NewProtocolMarshal(data []byte) module.ProtocolMarshal

func (mu *ModuleUtil) OnConfigLoaded(i func(app module.App)) error

func (mu *ModuleUtil) OnDestroy() error

func (mu *ModuleUtil) OnInit(settings CommonConf.Config) error

func (mu *ModuleUtil) OnModuleInit(internalFunc func(app module.App, module module.Module)) error

func (mu *ModuleUtil) OnStartup(internalFunc func(app module.App)) error

func (mu *ModuleUtil) Options() module.Options

func (mu *ModuleUtil) ProtocolMarshal(Result interface{}, Error interface{}) (module.ProtocolMarshal, string)

func (mu *ModuleUtil) Registry() ModuleRegistry.Registry

func (mu *ModuleUtil) RemoveSutDownService(s *ModuleRegistry.Service)

func (mu *ModuleUtil) RpcInvoke(module module.RPCModule, moduleID string, rpcInvokeResult *mqRPC.ResultInvokeST, ctxList ...context.Context) (result interface{}, err string)

func (mu *ModuleUtil) RpcInvokeNR(module module.RPCModule, moduleID string, rpcInvokeResult *mqRPC.ResultInvokeST) (err error)

func (mu *ModuleUtil) Run(mods ...module.Module) error

func (mu *ModuleUtil) SetMapRoute(fn func(app module.App, route string) string) error

func (mu *ModuleUtil) SetProtocolMarshal(protocolMarshal func(Result interface{}, Error interface{}) (module.ProtocolMarshal, string)) error

func (mu *ModuleUtil) Transport() *nats.Conn

func (mu *ModuleUtil) Watcher(s *ModuleRegistry.Service)