cherryAgent

Documentation

Index

• Constants
• type Agent
  • func NewAgent(app cherryFacade.IApplication, conn cherryFacade.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(route string, val interface{}, _ *cherryProto.Response)
  • func (a *Agent) RemoteAddr() string
  • func (a *Agent) Response(mid uint, v interface{}, isError ...bool)
  • func (a *Agent) Run()
  • func (a *Agent) Send(typ cherryMessage.Type, route string, mid uint, v interface{}, isError bool)
  • func (a *Agent) SendRaw(bytes []byte)
  • func (a *Agent) SetLastAt()
  • func (a *Agent) SetSession(session *cherrySession.Session)
• type AgentBackend
  • func NewAgentBackend(app cherryFacade.IApplication, rpcClient cherryFacade.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(route string, val interface{}, rsp *cherryProto.Response)
  • func (a *AgentBackend) RemoteAddr() string
  • func (a *AgentBackend) Response(mid uint, val interface{}, isError ...bool)
  • func (a *AgentBackend) SendRaw(_ []byte)
  • func (a *AgentBackend) SetSession(session *cherrySession.Session)
• type Options

Constants

const (
	WriteBacklog = 64
)

Types

type Agent

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

func NewAgent

func NewAgent(app cherryFacade.IApplication, conn cherryFacade.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(route string, val interface{}, _ *cherryProto.Response)

func (*Agent) RemoteAddr

func (a *Agent) RemoteAddr() string

func (*Agent) Response

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

func (*Agent) Run

func (a *Agent) Run()

func (*Agent) Send

func (a *Agent) Send(typ cherryMessage.Type, route string, mid uint, v interface{}, isError bool)

func (*Agent) SendRaw

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

func (*Agent) SetLastAt

func (a *Agent) SetLastAt()

func (*Agent) SetSession

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

type AgentBackend

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

func NewAgentBackend

func NewAgentBackend(app cherryFacade.IApplication, rpcClient cherryFacade.RPCClient, ip string) 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(route string, val interface{}, rsp *cherryProto.Response)

func (*AgentBackend) RemoteAddr

func (a *AgentBackend) RemoteAddr() string

func (*AgentBackend) Response

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

func (*AgentBackend) SendRaw

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

func (*AgentBackend) SetSession

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

type Options

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