cherryAgent

package

v1.1.17 Latest Latest Go to latest Published: Aug 18, 2021 License: MIT Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cherry-game/cherry

Links

Documentation ¶

Index ¶

Constants
type Agent
- func NewAgent(app cherryFacade.IApplication, conn cherryFacade.INetConn, opts *Options) *Agent
type AgentBackend
type Options

Constants ¶

View Source

const (
	WriteBacklog = 64
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Agent ¶

type Agent struct {
	sync.RWMutex
	*Options
	cherryFacade.IApplication
	Session *cherrySession.Session // session
	// 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{}) error

func (*Agent) Push ¶

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

func (*Agent) RPC ¶

func (a *Agent) RPC(route string, val interface{}) *cherryProto.Response

func (*Agent) RemoteAddr ¶

func (a *Agent) RemoteAddr() net.Addr

RemoteAddr implementation for session.NetworkEntity interface returns the remote network address.

func (*Agent) Response ¶

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

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) (err error)

func (*Agent) SendRaw ¶

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

func (*Agent) SetLastAt ¶

func (a *Agent) SetLastAt()

type AgentBackend ¶ added in v1.1.9

type AgentBackend struct {
	cherryFacade.IApplication
	Session   *cherrySession.Session
	RPCClient cherryFacade.RPCClient // rpc client
}

func (*AgentBackend) Close ¶ added in v1.1.9

func (a *AgentBackend) Close()

func (*AgentBackend) Kick ¶ added in v1.1.9

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

func (*AgentBackend) Push ¶ added in v1.1.9

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

func (*AgentBackend) RPC ¶ added in v1.1.9

func (a *AgentBackend) RPC(route string, val interface{}) *cherryProto.Response

func (*AgentBackend) RemoteAddr ¶ added in v1.1.9

func (a *AgentBackend) RemoteAddr() net.Addr

func (*AgentBackend) Response ¶ added in v1.1.9

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

func (*AgentBackend) SendRaw ¶ added in v1.1.9

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

type Options ¶

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL