app

Documentation

Overview

Package app mqant默认应用实现

Index

• func NewApp(opts ...module.Option) module.App
• type DefaultApp
  • func (app *DefaultApp) AddRPCSerialize(name string, Interface module.RPCSerialize) error
  • func (app *DefaultApp) Call(ctx context.Context, moduleType, _func string, param mqrpc.ParamOption, ...) (result interface{}, errstr string)
  • 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) 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) Invoke(module module.RPCModule, moduleType string, _func string, ...) (result interface{}, err string)
  • func (app *DefaultApp) InvokeNR(module module.RPCModule, moduleType string, _func string, ...) (err error)
  • 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) RpcInvokeNR(module module.RPCModule, moduleType string, _func 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

Functions

func NewApp

func NewApp(opts ...module.Option) module.App

NewApp 创建app

Types

type DefaultApp

type DefaultApp struct {
	// contains filtered or unexported fields
}

DefaultApp 默认应用

func (*DefaultApp) AddRPCSerialize

func (app *DefaultApp) AddRPCSerialize(name string, Interface module.RPCSerialize) error

AddRPCSerialize AddRPCSerialize

func (*DefaultApp) Call

func (app *DefaultApp) Call(ctx context.Context, moduleType, _func string, param mqrpc.ParamOption, opts ...selector.SelectOption) (result interface{}, errstr string)

Call Call

func (*DefaultApp) Configure

func (app *DefaultApp) Configure(settings conf.Config) error

Configure 重设应用配置

func (*DefaultApp) GetModuleInited

func (app *DefaultApp) GetModuleInited() func(app module.App, module module.Module)

GetModuleInited GetModuleInited

func (*DefaultApp) GetProcessID

func (app *DefaultApp) GetProcessID() string

GetProcessID 获取应用分组ID

func (*DefaultApp) GetRPCSerialize

func (app *DefaultApp) GetRPCSerialize() map[string]module.RPCSerialize

GetRPCSerialize GetRPCSerialize

func (*DefaultApp) GetRouteServer

func (app *DefaultApp) GetRouteServer(filter string, opts ...selector.SelectOption) (s module.ServerSession, err error)

GetRouteServer 通过选择器过滤服务实例

func (*DefaultApp) GetServerByID

func (app *DefaultApp) GetServerByID(serverID string) (module.ServerSession, error)

GetServerByID 通过服务ID获取服务实例

func (*DefaultApp) GetServerById

func (app *DefaultApp) GetServerById(serverID string) (module.ServerSession, error)

GetServerById 通过服务ID获取服务实例 Deprecated: 因为命名规范问题函数将废弃,请用GetServerById代替

func (*DefaultApp) GetServerBySelector

func (app *DefaultApp) GetServerBySelector(serviceName string, opts ...selector.SelectOption) (module.ServerSession, error)

GetServerBySelector 获取服务实例,可设置选择器

func (*DefaultApp) GetServersByType

func (app *DefaultApp) GetServersByType(serviceName string) []module.ServerSession

GetServersByType 通过服务类型获取服务实例列表

func (*DefaultApp) GetSettings

func (app *DefaultApp) GetSettings() conf.Config

GetSettings 获取配置

func (*DefaultApp) Invoke

func (app *DefaultApp) Invoke(module module.RPCModule, moduleType string, _func string, params ...interface{}) (result interface{}, err string)

Invoke Invoke

func (*DefaultApp) InvokeNR

func (app *DefaultApp) InvokeNR(module module.RPCModule, moduleType string, _func string, params ...interface{}) (err error)

InvokeNR InvokeNR

func (*DefaultApp) NewProtocolMarshal

func (app *DefaultApp) NewProtocolMarshal(data []byte) module.ProtocolMarshal

NewProtocolMarshal 创建RPC数据包装器

func (*DefaultApp) OnConfigurationLoaded

func (app *DefaultApp) OnConfigurationLoaded(_func func(app module.App)) error

OnConfigurationLoaded 设置配置初始化完成后回调

func (*DefaultApp) OnDestroy

func (app *DefaultApp) OnDestroy() error

OnDestroy 应用退出

func (*DefaultApp) OnInit

func (app *DefaultApp) OnInit(settings conf.Config) error

OnInit 初始化

func (*DefaultApp) OnModuleInited

func (app *DefaultApp) OnModuleInited(_func func(app module.App, module module.Module)) error

OnModuleInited 设置模块初始化完成后回调

func (*DefaultApp) OnStartup

func (app *DefaultApp) OnStartup(_func func(app module.App)) error

OnStartup 设置应用启动完成后回调

func (*DefaultApp) Options

func (app *DefaultApp) Options() module.Options

Options 应用配置

func (*DefaultApp) ProtocolMarshal

func (app *DefaultApp) ProtocolMarshal(Trace string, Result interface{}, Error string) (module.ProtocolMarshal, string)

ProtocolMarshal RPC数据包装器

func (*DefaultApp) Registry

func (app *DefaultApp) Registry() registry.Registry

Registry Registry

func (*DefaultApp) RpcCall

func (app *DefaultApp) RpcCall(ctx context.Context, moduleType, _func string, param mqrpc.ParamOption, opts ...selector.SelectOption) (result interface{}, errstr string)

RpcCall RpcCall Deprecated: 因为命名规范问题函数将废弃,请用Call代替

func (*DefaultApp) RpcInvoke

func (app *DefaultApp) RpcInvoke(module module.RPCModule, moduleType string, _func string, params ...interface{}) (result interface{}, err string)

RpcInvoke RpcInvoke Deprecated: 因为命名规范问题函数将废弃,请用Invoke代替

func (*DefaultApp) RpcInvokeNR

func (app *DefaultApp) RpcInvokeNR(module module.RPCModule, moduleType string, _func string, params ...interface{}) (err error)

RpcInvokeNR RpcInvokeNR Deprecated: 因为命名规范问题函数将废弃,请用InvokeNR代替

func (*DefaultApp) Run

func (app *DefaultApp) Run(mods ...module.Module) error

Run 运行应用

func (*DefaultApp) SetMapRoute

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

SetMapRoute 设置路由器

func (*DefaultApp) SetProtocolMarshal

func (app *DefaultApp) SetProtocolMarshal(protocolMarshal func(Trace string, Result interface{}, Error string) (module.ProtocolMarshal, string)) error

SetProtocolMarshal 设置RPC数据包装器

func (*DefaultApp) Transport

func (app *DefaultApp) Transport() *nats.Conn

Transport Transport

func (*DefaultApp) Watcher

func (app *DefaultApp) Watcher(node *registry.Node)

Watcher Watcher

func (*DefaultApp) WorkDir

func (app *DefaultApp) WorkDir() string

WorkDir 获取进程工作目录