agent

Documentation

Index

• Constants
• Variables
• type Agent
  • func (a *Agent) GetConnInfo() *acceptor.ConnInfo
  • func (a *Agent) GetId() int64
  • func (a *Agent) GetLastTimeOnline() int64
  • func (a *Agent) GetLatency() int64
  • func (a *Agent) GetSession() *session.Session
  • func (a *Agent) GetStatus() int32
  • func (a *Agent) IsClosed() bool
  • func (a *Agent) LocalAddr() net.Addr
  • func (a *Agent) RemoteAddr() net.Addr
  • func (a *Agent) Send(in interface{}, name ...string) error
  • func (a *Agent) SendData(data []byte)
  • func (a *Agent) SetLastAt()
  • func (a *Agent) SetStatus(state int32)
  • func (a *Agent) Start()
  • func (a *Agent) Stop() error
• type AgentFacotry
  • func NewAgentFactory(config *config.Config, pool session.SessionPool, ...) *AgentFacotry
  • func (af *AgentFacotry) NewAgent(conn acceptor.AcceptorConn) *Agent

Constants

const (

	// StatusStart status
	StatusStart int32
	// StatusHandshake status
	StatusHandshake
	// StatusWorking status
	StatusWorking
	// StatusClosed status
	StatusClosed
)

Variables

var (
	ErrCloseClosedSession = errors.New("close closed session")
)

Types

type Agent

type Agent struct {
	AgentID int64 // user id
	// contains filtered or unexported fields
}

Agent corresponds to a user and is used for storing raw Conn information

func (*Agent) GetConnInfo

func (a *Agent) GetConnInfo() *acceptor.ConnInfo

func (*Agent) GetId

func (a *Agent) GetId() int64

func (*Agent) GetLastTimeOnline

func (a *Agent) GetLastTimeOnline() int64

func (*Agent) GetLatency

func (a *Agent) GetLatency() int64

func (*Agent) GetSession

func (a *Agent) GetSession() *session.Session

func (*Agent) GetStatus

func (a *Agent) GetStatus() int32

func (*Agent) IsClosed

func (a *Agent) IsClosed() bool

func (*Agent) LocalAddr

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

func (*Agent) RemoteAddr

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

func (*Agent) Send

func (a *Agent) Send(in interface{}, name ...string) error

Send Message

func (*Agent) SendData

func (a *Agent) SendData(data []byte)

func (*Agent) SetLastAt

func (a *Agent) SetLastAt()

func (*Agent) SetStatus

func (a *Agent) SetStatus(state int32)

func (*Agent) Start

func (a *Agent) Start()

func (*Agent) Stop

func (a *Agent) Stop() error

Stop close the agent

type AgentFacotry

type AgentFacotry struct {
	// contains filtered or unexported fields
}

AgentFacotry is the facotry to create the agent

func NewAgentFactory

func NewAgentFactory(config *config.Config,
	pool session.SessionPool,
	messageServer *message.MessageServer) *AgentFacotry

func (*AgentFacotry) NewAgent

func (af *AgentFacotry) NewAgent(conn acceptor.AcceptorConn) *Agent