Versions in this module Expand all Collapse all v2 v2.9.1 Dec 25, 2023 Changes in this version + type Agent interface + AnswerWithError func(ctx context.Context, mid uint, err error) + Close func() error + GetSession func() session.Session + GetStatus func() int32 + Handle func() + IPVersion func() string + Kick func(ctx context.Context) error + Push func(route string, v interface{}) error + RemoteAddr func() net.Addr + ResponseMID func(ctx context.Context, mid uint, v interface{}, isError ...bool) error + SendHandshakeErrorResponse func() error + SendHandshakeResponse func() error + SendRequest func(ctx context.Context, serverID, route string, v interface{}) (*protos.Response, error) + SetLastAt func() + SetStatus func(state int32) + String func() string + type AgentFactory interface + CreateAgent func(conn net.Conn) Agent + func NewAgentFactory(appDieChan chan bool, decoder codec.PacketDecoder, encoder codec.PacketEncoder, ...) AgentFactory + type Remote struct + Session session.Session + 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) SendRequest(ctx context.Context, serverID, reqRoute string, v interface{}) (*protos.Response, error) Other modules containing this package github.com/pandazxx/pitaya
Go to main page