Versions in this module Expand all Collapse all v1 v1.2.1 Mar 15, 2020 Changes in this version + func NewApp(opts ...module.Option) module.App + type DefaultApp struct + func (app *DefaultApp) AddRPCSerialize(name string, Interface module.RPCSerialize) error + func (app *DefaultApp) Configure(settings conf.Config) error + func (app *DefaultApp) GetModuleInited() func(app module.App, module module.Module) + func (app *DefaultApp) GetProcessID() string + func (app *DefaultApp) GetRPCSerialize() map[string]module.RPCSerialize + func (app *DefaultApp) GetRouteServer(filter string, opts ...selector.SelectOption) (s module.ServerSession, err error) + func (app *DefaultApp) GetServerById(serverId string) (module.ServerSession, error) + func (app *DefaultApp) GetServerBySelector(serviceName string, opts ...selector.SelectOption) (module.ServerSession, error) + func (app *DefaultApp) GetServersByType(serviceName string) []module.ServerSession + func (app *DefaultApp) GetSettings() conf.Config + func (app *DefaultApp) NewProtocolMarshal(data []byte) module.ProtocolMarshal + func (app *DefaultApp) OnConfigurationLoaded(_func func(app module.App)) error + func (app *DefaultApp) OnDestroy() error + func (app *DefaultApp) OnInit(settings conf.Config) error + func (app *DefaultApp) OnModuleInited(_func func(app module.App, module module.Module)) error + func (app *DefaultApp) OnStartup(_func func(app module.App)) error + func (app *DefaultApp) Options() module.Options + func (app *DefaultApp) ProtocolMarshal(Trace string, Result interface{}, Error string) (module.ProtocolMarshal, string) + func (app *DefaultApp) Registry() registry.Registry + func (app *DefaultApp) RpcCall(ctx context.Context, moduleType, _func string, param mqrpc.ParamOption, ...) (result interface{}, errstr string) + func (app *DefaultApp) RpcInvoke(module module.RPCModule, moduleType string, _func string, ...) (result interface{}, err string) + func (app *DefaultApp) RpcInvokeArgs(module module.RPCModule, moduleType string, _func string, ArgsType []string, ...) (result interface{}, err string) + func (app *DefaultApp) RpcInvokeNR(module module.RPCModule, moduleType string, _func string, ...) (err error) + func (app *DefaultApp) RpcInvokeNRArgs(module module.RPCModule, moduleType string, _func string, ArgsType []string, ...) (err error) + func (app *DefaultApp) Run(mods ...module.Module) error + func (app *DefaultApp) SetMapRoute(fn func(app module.App, route string) string) error + func (app *DefaultApp) SetProtocolMarshal(...) error + func (app *DefaultApp) Transport() *nats.Conn + func (app *DefaultApp) Watcher(node *registry.Node) + func (app *DefaultApp) WorkDir() string