Versions in this module Expand all Collapse all v0 v0.0.1 Oct 12, 2022 Changes in this version + const WriteBacklog + type Agent struct + func NewAgent(app cfacade.IApplication, conn cfacade.INetConn, opts *Options) *Agent + func (a *Agent) Close() + func (a *Agent) Kick(reason interface{}) + func (a *Agent) Push(route string, val interface{}) + func (a *Agent) RPC(nodeId string, route string, req proto.Message, _ proto.Message) int32 + func (a *Agent) RemoteAddr() string + func (a *Agent) Response(mid uint, v interface{}, isError ...bool) + func (a *Agent) Run() + func (a *Agent) SendRaw(bytes []byte) + func (a *Agent) SetLastAt() + func (a *Agent) SetSession(session *csession.Session) + type AgentBackend struct + func NewAgentBackend(app cfacade.IApplication, rpcClient cfacade.RPCClient, ip string) AgentBackend + func (a *AgentBackend) Close() + func (a *AgentBackend) Kick(reason interface{}) + func (a *AgentBackend) Push(route string, val interface{}) + func (a *AgentBackend) RPC(nodeId string, route string, req proto.Message, rsp proto.Message) int32 + func (a *AgentBackend) RemoteAddr() string + func (a *AgentBackend) Response(mid uint, val interface{}, isError ...bool) + func (a *AgentBackend) SendRaw(data []byte) + func (a *AgentBackend) SetSession(session *csession.Session) + type Options struct + Commands map[cpkg.Type]ccmd.ICommand + Heartbeat time.Duration