Versions in this module Expand all Collapse all v0 v0.0.1 Oct 12, 2022 Changes in this version + func AddNodeRouter(nodeType string, routingFunc crouter.RoutingFunc) + func Configure(profilePath, profileName, nodeId string) cfacade.IApplication + func GetConnectors() []cfacade.IConnector + func GetRPC() cfacade.RPCClient + func Kick(nodeId string, uid cfacade.UID, val interface{}, close bool) error + func PostEvent(event cfacade.IEvent) + func PublishRemote(nodeId string, route string, arg interface{}) + func PublishRemoteByRoute(route string, arg interface{}) + func Push(frontendId string, route string, uid cfacade.UID, val interface{}) error + func RegisterCommand(command ccommand.ICommand) + func RegisterComponent(component ...cfacade.IComponent) + func RegisterConnector(connector cfacade.IConnector) + func RegisterHandler(handler ...cfacade.IHandler) + func RegisterHandlerGroup(group ...*chandler.HandlerGroup) + func RequestRemote(nodeId string, route string, arg, reply interface{}, timeout ...time.Duration) int32 + func RequestRemoteByRoute(route string, arg, reply interface{}, timeout ...time.Duration) int32 + func Run(isFrontend bool, nodeMode NodeMode) + func SetDataCompression(compression bool) + func SetDictionary(dict map[string]uint16) + func SetHandlerOptions(opts ...chandler.Option) + func SetHandshake(key string, value interface{}) + func SetHeartbeat(t time.Duration) + func SetOnShutdown(fn ...func()) + func SetPacketCodec(codec cfacade.IPacketCodec) + func SetSerializer(serializer cfacade.ISerializer) + type Application struct + func App() *Application + func NewApp(profilePath, profileName, nodeId string) *Application + func (a *Application) All() []cfacade.IComponent + func (a *Application) DieChan() chan bool + func (a *Application) Find(name string) cfacade.IComponent + func (a *Application) IsFrontend() bool + func (a *Application) NodeMode() NodeMode + func (a *Application) OnShutdown(fn ...func()) + func (a *Application) Register(components ...cfacade.IComponent) + func (a *Application) Remove(name string) cfacade.IComponent + func (a *Application) Running() bool + func (a *Application) SetPacketCodec(codec cfacade.IPacketCodec) + func (a *Application) SetSerializer(serializer cfacade.ISerializer) + func (a *Application) Shutdown() + func (a *Application) StartTime() string + func (a *Application) Startup(components ...cfacade.IComponent) + type NodeMode byte + const Cluster + const Standalone