agent

Documentation

Index

• type Agent
• type AgentFactory
  • func NewAgentFactory(appDieChan chan bool, decoder codec.PacketDecoder, encoder codec.PacketEncoder, ...) AgentFactory
• type Remote
  • func NewRemote(sess *protos.Session, reply string, rpcClient cluster.RPCClient, ...) (*Remote, error)
  • func (a *Remote) Close() error
  • func (a *Remote) Kick(ctx context.Context) error
  • func (a *Remote) Push(route string, v interface{}) error
  • func (a *Remote) RemoteAddr() net.Addr
  • func (a *Remote) ResponseMID(ctx context.Context, mid uint, v interface{}, isError ...bool) error
  • func (a *Remote) ResponseRoute(ctx context.Context, mid uint, route string, v interface{}, isError ...bool) error
  • func (a *Remote) SendRequest(ctx context.Context, serverID, reqRoute string, v interface{}) (*protos.Response, error)

Types

type Agent

type Agent interface {
	GetSession() session.Session
	Push(route string, v interface{}) error
	ResponseMID(ctx context.Context, mid uint, v interface{}, isError ...bool) error
	ResponseRoute(ctx context.Context, mid uint, route string, v interface{}, isError ...bool) error
	Close() error
	RemoteAddr() net.Addr
	String() string
	GetStatus() int32
	Kick(ctx context.Context) error
	SetLastAt()
	SetStatus(state int32)
	Handle()
	IPVersion() string
	SendHandshakeResponse() error
	SendHandshakeErrorResponse() error
	SendHeartbeat() error
	SendRequest(ctx context.Context, serverID, route string, v interface{}) (*protos.Response, error)
	AnswerWithError(ctx context.Context, mid uint, err error)
}

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

type AgentFactory

type AgentFactory interface {
	CreateAgent(conn net.Conn) Agent
}

AgentFactory factory for creating Agent instances

func NewAgentFactory

func NewAgentFactory(
	appDieChan chan bool,
	decoder codec.PacketDecoder,
	encoder codec.PacketEncoder,
	serializer serialize.Serializer,
	heartbeatTimeout time.Duration,
	messageEncoder message.Encoder,
	messagesBufferSize int,
	sessionPool session.SessionPool,
	metricsReporters []metrics.Reporter,
) AgentFactory

NewAgentFactory ctor

type Remote

type Remote struct {
	Session session.Session // session
	// contains filtered or unexported fields
}

Remote corresponding to another server

func NewRemote

func NewRemote(
	sess *protos.Session,
	reply string,
	rpcClient cluster.RPCClient,
	encoder codec.PacketEncoder,
	serializer serialize.Serializer,
	serviceDiscovery cluster.ServiceDiscovery,
	frontendID string,
	messageEncoder message.Encoder,
	sessionPool session.SessionPool,
) (*Remote, error)

NewRemote create new Remote instance

func (*Remote) Close

func (a *Remote) Close() error

Close closes the remote

func (*Remote) Kick

func (a *Remote) Kick(ctx context.Context) error

Kick kicks the user

func (*Remote) Push

func (a *Remote) Push(route string, v interface{}) error

Push pushes the message to the user

func (*Remote) RemoteAddr

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

RemoteAddr returns the remote address of the user

func (*Remote) ResponseMID

func (a *Remote) ResponseMID(ctx context.Context, mid uint, v interface{}, isError ...bool) error

ResponseMID reponds the message with mid to the user

func (*Remote) ResponseRoute

func (a *Remote) ResponseRoute(ctx context.Context, mid uint, route string, v interface{}, isError ...bool) error

func (*Remote) SendRequest

func (a *Remote) SendRequest(ctx context.Context, serverID, reqRoute string, v interface{}) (*protos.Response, error)

SendRequest sends a request to a server