Documentation ¶
Index ¶
- func NewApp(opts ...module.Option) module.App
- type ModuleUtil
- 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, ...) (result interface{}, err string)
- func (mu *ModuleUtil) RpcInvokeNR(module module.RPCModule, moduleID string, ...) (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(...) error
- func (mu *ModuleUtil) Transport() *nats.Conn
- func (mu *ModuleUtil) Watcher(s *ModuleRegistry.Service)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ModuleUtil ¶
type ModuleUtil struct {
// contains filtered or unexported fields
}
func (*ModuleUtil) AddRPCSerialize ¶
func (mu *ModuleUtil) AddRPCSerialize(name string, Interface module.RPCSerialize) error
func (*ModuleUtil) Configure ¶
func (mu *ModuleUtil) Configure(settings CommonConf.Config) error
func (*ModuleUtil) GetModuleInit ¶
func (mu *ModuleUtil) GetModuleInit() func(app module.App, module module.Module)
func (*ModuleUtil) GetRPCSerialize ¶
func (mu *ModuleUtil) GetRPCSerialize() map[string]module.RPCSerialize
func (*ModuleUtil) GetRandomServerByType ¶
func (mu *ModuleUtil) GetRandomServerByType(typeName string) (module.ServerSession, error)
func (*ModuleUtil) GetServerByID ¶
func (mu *ModuleUtil) GetServerByID(id string) (module.ServerSession, error)
func (*ModuleUtil) GetServersByType ¶
func (mu *ModuleUtil) GetServersByType(typeName string) ([]module.ServerSession, error)
func (*ModuleUtil) GetServiceList ¶
func (mu *ModuleUtil) GetServiceList() ([]module.ServerSession, error)
func (*ModuleUtil) GetSettings ¶
func (mu *ModuleUtil) GetSettings() CommonConf.Config
func (*ModuleUtil) NewProtocolMarshal ¶
func (mu *ModuleUtil) NewProtocolMarshal(data []byte) module.ProtocolMarshal
func (*ModuleUtil) OnConfigLoaded ¶
func (mu *ModuleUtil) OnConfigLoaded(i func(app module.App)) error
func (*ModuleUtil) OnDestroy ¶
func (mu *ModuleUtil) OnDestroy() error
func (*ModuleUtil) OnInit ¶
func (mu *ModuleUtil) OnInit(settings CommonConf.Config) error
func (*ModuleUtil) OnModuleInit ¶
func (*ModuleUtil) OnStartup ¶
func (mu *ModuleUtil) OnStartup(internalFunc func(app module.App)) error
func (*ModuleUtil) Options ¶
func (mu *ModuleUtil) Options() module.Options
func (*ModuleUtil) ProtocolMarshal ¶
func (mu *ModuleUtil) ProtocolMarshal(Result interface{}, Error interface{}) (module.ProtocolMarshal, string)
func (*ModuleUtil) Registry ¶
func (mu *ModuleUtil) Registry() ModuleRegistry.Registry
func (*ModuleUtil) RemoveSutDownService ¶
func (mu *ModuleUtil) RemoveSutDownService(s *ModuleRegistry.Service)
移除已註銷的服務
func (*ModuleUtil) RpcInvoke ¶
func (mu *ModuleUtil) RpcInvoke(module module.RPCModule, moduleID string, rpcInvokeResult *mqRPC.ResultInvokeST, ctxList ...context.Context) (result interface{}, err string)
func (*ModuleUtil) RpcInvokeNR ¶
func (mu *ModuleUtil) RpcInvokeNR(module module.RPCModule, moduleID string, rpcInvokeResult *mqRPC.ResultInvokeST) (err error)
func (*ModuleUtil) SetMapRoute ¶
func (*ModuleUtil) SetProtocolMarshal ¶
func (mu *ModuleUtil) SetProtocolMarshal(protocolMarshal func(Result interface{}, Error interface{}) (module.ProtocolMarshal, string)) error
func (*ModuleUtil) Transport ¶
func (mu *ModuleUtil) Transport() *nats.Conn
func (*ModuleUtil) Watcher ¶
func (mu *ModuleUtil) Watcher(s *ModuleRegistry.Service)
把註銷的服務serverSession刪除
Click to show internal directories.
Click to hide internal directories.