cherryAgent

Documentation

Index

• Constants
• type Agent
  • 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, _ interface{}) int32
  • 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
  • func NewAgentBackend(app cfacade.IApplication, rpcClient cfacade.RPCClient) 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, rsp interface{}) int32
  • 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

Constants

const (
	WriteBacklog = 64
)

Types

type Agent

type Agent struct {
	sync.RWMutex
	*Options
	cfacade.IApplication
	// contains filtered or unexported fields
}

func NewAgent

func NewAgent(app cfacade.IApplication, conn cfacade.INetConn, opts *Options) *Agent

func (*Agent) Close

func (a *Agent) Close()

func (*Agent) Kick

func (a *Agent) Kick(reason interface{})

func (*Agent) Push

func (a *Agent) Push(route string, val interface{})

func (*Agent) RPC

func (a *Agent) RPC(nodeId string, route string, req, _ interface{}) int32

func (*Agent) Response

func (a *Agent) Response(mid uint, v interface{}, isError ...bool)

func (*Agent) Run

func (a *Agent) Run()

func (*Agent) SendRaw

func (a *Agent) SendRaw(bytes []byte)

func (*Agent) SetLastAt

func (a *Agent) SetLastAt()

func (*Agent) SetSession

func (a *Agent) SetSession(session *csession.Session)

type AgentBackend

type AgentBackend struct {
	cfacade.IApplication
	// contains filtered or unexported fields
}

func NewAgentBackend

func NewAgentBackend(app cfacade.IApplication, rpcClient cfacade.RPCClient) AgentBackend

func (*AgentBackend) Close

func (a *AgentBackend) Close()

func (*AgentBackend) Kick

func (a *AgentBackend) Kick(reason interface{})

func (*AgentBackend) Push

func (a *AgentBackend) Push(route string, val interface{})

func (*AgentBackend) RPC

func (a *AgentBackend) RPC(nodeId string, route string, req, rsp interface{}) int32

func (*AgentBackend) Response

func (a *AgentBackend) Response(mid uint, val interface{}, isError ...bool)

func (*AgentBackend) SendRaw

func (a *AgentBackend) SendRaw(data []byte)

func (*AgentBackend) SetSession

func (a *AgentBackend) SetSession(session *csession.Session)

type Options

type Options struct {
	Heartbeat time.Duration               // heartbeat(sec)
	Commands  map[cpkg.Type]ccmd.ICommand // commands
}