gatebase

package

Go to main page

Versions in this module

v1

v1.1.7

Nov 8, 2025

Changes in this version

type Delegate

+ func (this *Delegate) SessionsRange(f func(key, value any) bool)

v1.1.6

Nov 2, 2025

v1.1.5

Nov 2, 2025

v1.1.4

Nov 2, 2025

Changes in this version

type GateBase

+ func (this *GateBase) SetDelegater(handler gate.IDelegater) error

v1.1.3

Nov 2, 2025

Changes in this version

type GateBase

+ func (this *GateBase) GetRecvPackHandler() gate.IRecvPackHandler

+ func (this *GateBase) SetRecvPackHandler(handler gate.IRecvPackHandler) error

type TCPClientAgent

+ func (this *TCPClientAgent) OnRecvPack(pack *gate.Pack) error

type WSClientAgent

+ func (this *WSClientAgent) OnRecvPack(pack *gate.Pack) error

v1.1.2

Nov 2, 2025

Changes in this version

+ func NewTCPClientAgent() gate.IClientAgent

+ func NewWSClientAgent() gate.IClientAgent

+ type TCPClientAgent struct

+ func (this *TCPClientAgent) Close()

+ func (this *TCPClientAgent) ConnTime() time.Time

+ func (this *TCPClientAgent) GetError() error

+ func (this *TCPClientAgent) GetSession() gate.ISession

+ func (this *TCPClientAgent) Init(impl gate.IClientAgent, gt gate.IGate, conn network.Conn) error

+ func (this *TCPClientAgent) IsClosed() bool

+ func (this *TCPClientAgent) IsShaked() bool

+ func (this *TCPClientAgent) OnClose() error

+ func (this *TCPClientAgent) OnHandRecvPack(pack *gate.Pack) error

+ func (this *TCPClientAgent) OnReadDecodingPack() (*gate.Pack, error)

+ func (this *TCPClientAgent) OnWriteEncodingPack(pack *gate.Pack) []byte

+ func (this *TCPClientAgent) RecvNum() int64

+ func (this *TCPClientAgent) Run() (err error)

+ func (this *TCPClientAgent) SendNum() int64

+ func (this *TCPClientAgent) SendPack(pack *gate.Pack) error

+ type WSClientAgent struct

+ func (this *WSClientAgent) Close()

+ func (this *WSClientAgent) ConnTime() time.Time

+ func (this *WSClientAgent) GetError() error

+ func (this *WSClientAgent) GetSession() gate.ISession

+ func (this *WSClientAgent) Init(impl gate.IClientAgent, gt gate.IGate, conn network.Conn) error

+ func (this *WSClientAgent) IsClosed() bool

+ func (this *WSClientAgent) IsShaked() bool

+ func (this *WSClientAgent) OnClose() error

+ func (this *WSClientAgent) OnHandRecvPack(pack *gate.Pack) error

+ func (this *WSClientAgent) OnReadDecodingPack() (*gate.Pack, error)

+ func (this *WSClientAgent) OnWriteEncodingPack(pack *gate.Pack) []byte

+ func (this *WSClientAgent) RecvNum() int64

+ func (this *WSClientAgent) Run() (err error)

+ func (this *WSClientAgent) SendNum() int64

+ func (this *WSClientAgent) SendPack(pack *gate.Pack) error

v1.1.1

Oct 31, 2025

Changes in this version

+ func NewSession(data []byte) (gate.ISession, error)

+ func NewSessionByMap(data map[string]any) (gate.ISession, error)

+ func NewTCPConnAgent() gate.IConnAgent

+ func NewWSConnAgent() gate.IConnAgent

+ type Delegate struct

+ func NewDelegate(gate gate.IGate) *Delegate

+ func (this *Delegate) Connect(a gate.IConnAgent)

+ func (this *Delegate) DisConnect(a gate.IConnAgent)

+ func (this *Delegate) GetAgent(sessionId string) (gate.IConnAgent, error)

+ func (this *Delegate) GetAgentNum() int

+ func (this *Delegate) OnDestroy()

+ func (this *Delegate) OnRpcBind(ctx context.Context, sessionId string, userId string) (gate.ISession, error)

+ func (this *Delegate) OnRpcBroadcast(ctx context.Context, topic string, body []byte) (int64, error)

+ func (this *Delegate) OnRpcClose(ctx context.Context, sessionId string) (bool, error)

+ func (this *Delegate) OnRpcConnected(ctx context.Context, sessionId string) (bool, error)

+ func (this *Delegate) OnRpcDel(ctx context.Context, sessionId string, key string) (gate.ISession, error)

+ func (this *Delegate) OnRpcLoad(ctx context.Context, sessionId string) (gate.ISession, error)

+ func (this *Delegate) OnRpcPush(ctx context.Context, sessionId string, settings map[string]string) (gate.ISession, error)

+ func (this *Delegate) OnRpcSend(ctx context.Context, sessionId string, topic string, body []byte) (bool, error)

+ func (this *Delegate) OnRpcSet(ctx context.Context, sessionId string, key string, value string) (gate.ISession, error)

+ func (this *Delegate) OnRpcUnBind(ctx context.Context, sessionId string) (gate.ISession, error)

+ type GateBase struct

+ func (this *GateBase) GetAgentLearner() gate.IAgentLearner

+ func (this *GateBase) GetDelegater() gate.IDelegater

+ func (this *GateBase) GetGuestJudger() func(session gate.ISession) bool

+ func (this *GateBase) GetRouteHandler() gate.RouteHandler

+ func (this *GateBase) GetSendMessageHook() gate.SendMessageHook

+ func (this *GateBase) GetSessionLearner() gate.ISessionLearner

+ func (this *GateBase) GetShakeHandler() func(r *http.Request) error

+ func (this *GateBase) GetStorageHandler() (storager gate.StorageHandler)

+ func (this *GateBase) GetType() string

+ func (this *GateBase) Init(subclass app.IRPCModule, settings *conf.ModuleSettings, opts ...gate.Option)

+ func (this *GateBase) OnAppConfigurationLoaded()

+ func (this *GateBase) OnConfChanged(settings *conf.ModuleSettings)

+ func (this *GateBase) OnDestroy()

+ func (this *GateBase) Options() gate.Options

+ func (this *GateBase) Run(closeSig chan bool)

+ func (this *GateBase) SetAgentCreater(cfunc func(netTyp string) gate.IConnAgent) error

+ func (this *GateBase) SetAgentLearner(learner gate.IAgentLearner) error

+ func (this *GateBase) SetGateHandler(handler gate.IDelegater) error

+ func (this *GateBase) SetGuestJudger(judger func(session gate.ISession) bool) error

+ func (this *GateBase) SetRouteHandler(router gate.RouteHandler) error

+ func (this *GateBase) SetSendMessageHook(hook gate.SendMessageHook) error

+ func (this *GateBase) SetSessionLearner(learner gate.ISessionLearner) error

+ func (this *GateBase) SetShakeHandler(handler func(r *http.Request) error) error

+ func (this *GateBase) SetStorageHandler(storager gate.StorageHandler) error

+ func (this *GateBase) Version() string

+ type SessionImp struct

+ IP string

+ Network string

+ ServerId string

+ SessionId string

+ Settings map[string]string

+ SpanId string

+ TraceId string

+ UserId string

+ type TCPConnAgent struct

+ func (this *TCPConnAgent) Close()

+ func (this *TCPConnAgent) ConnTime() time.Time

+ func (this *TCPConnAgent) GetError() error

+ func (this *TCPConnAgent) GetSession() gate.ISession

+ func (this *TCPConnAgent) Init(impl gate.IConnAgent, gt gate.IGate, conn network.Conn) error

+ func (this *TCPConnAgent) IsClosed() bool

+ func (this *TCPConnAgent) IsShaked() bool

+ func (this *TCPConnAgent) OnClose() error

+ func (this *TCPConnAgent) OnHandRecvPack(pack *gate.Pack) error

+ func (this *TCPConnAgent) OnReadDecodingPack() (*gate.Pack, error)

+ func (this *TCPConnAgent) OnWriteEncodingPack(pack *gate.Pack) []byte

+ func (this *TCPConnAgent) RecvNum() int64

+ func (this *TCPConnAgent) Run() (err error)

+ func (this *TCPConnAgent) SendNum() int64

+ func (this *TCPConnAgent) SendPack(pack *gate.Pack) error

+ type WSConnAgent struct

+ func (this *WSConnAgent) Close()

+ func (this *WSConnAgent) ConnTime() time.Time

+ func (this *WSConnAgent) GetError() error

+ func (this *WSConnAgent) GetSession() gate.ISession

+ func (this *WSConnAgent) Init(impl gate.IConnAgent, gt gate.IGate, conn network.Conn) error

+ func (this *WSConnAgent) IsClosed() bool

+ func (this *WSConnAgent) IsShaked() bool

+ func (this *WSConnAgent) OnClose() error

+ func (this *WSConnAgent) OnHandRecvPack(pack *gate.Pack) error

+ func (this *WSConnAgent) OnReadDecodingPack() (*gate.Pack, error)

+ func (this *WSConnAgent) OnWriteEncodingPack(pack *gate.Pack) []byte

+ func (this *WSConnAgent) RecvNum() int64

+ func (this *WSConnAgent) Run() (err error)

+ func (this *WSConnAgent) SendNum() int64

+ func (this *WSConnAgent) SendPack(pack *gate.Pack) error

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