gate

package

Go to main page

Versions in this module

v1

v1.1.7

Nov 8, 2025

Changes in this version

+ const RPC_CLIENT_DISCONNECT_MSG

type IDelegater

+ SessionsRange func(f func(key, value any) bool)

type ISession

+ GetUserData func() any

v1.1.6

Nov 2, 2025

v1.1.5

Nov 2, 2025

Changes in this version

type ISessionLearner

+ OnConnect func(a ISession)

+ OnDisConnect func(a ISession)

v1.1.4

Nov 2, 2025

Changes in this version

+ type FunRecvPackHandler func(session ISession, pack *Pack) error

+ type FunSendMessageHook func(session ISession, topic string, msg []byte) ([]byte, error)

v1.1.3

Nov 2, 2025

Changes in this version

type IGate

+ GetRecvPackHandler func() IRecvPackHandler

+ type IRecvPackHandler interface

+ OnHandleRecvPack func(pack *Pack) error

v1.1.2

Nov 2, 2025

Changes in this version

+ type IClientAgent interface

+ Close func()

+ ConnTime func() time.Time

+ GetError func() error

+ GetSession func() ISession

+ Init func(impl IClientAgent, gate IGate, conn network.Conn) error

+ IsClosed func() bool

+ IsShaked func() bool

+ OnClose func() error

+ OnHandRecvPack func(pack *Pack) error

+ OnReadDecodingPack func() (*Pack, error)

+ OnWriteEncodingPack func(pack *Pack) []byte

+ RecvNum func() int64

+ Run func() (err error)

+ SendNum func() int64

+ SendPack func(pack *Pack) error

v1.1.1

Oct 31, 2025

Changes in this version

+ const CONTEXT_TRANSKEY_SESSION

+ const PACK_BODY_DEFAULT_SIZE_IN_POOL

+ const PACK_HEAD_MSG_ID_LEN_SIZE

+ const PACK_HEAD_TOTAL_LEN_SIZE

+ const RPC_CLIENT_MSG

+ type GenResponseHandler interface

+ type IAgentLearner interface

+ Connect func(a IConnAgent)

+ DisConnect func(a IConnAgent)

+ type IConnAgent interface

+ Close func()

+ ConnTime func() time.Time

+ GetError func() error

+ GetSession func() ISession

+ Init func(impl IConnAgent, gate IGate, conn network.Conn) error

+ IsClosed func() bool

+ IsShaked func() bool

+ OnClose func() error

+ OnHandRecvPack func(pack *Pack) error

+ OnReadDecodingPack func() (*Pack, error)

+ OnWriteEncodingPack func(pack *Pack) []byte

+ RecvNum func() int64

+ Run func() (err error)

+ SendNum func() int64

+ SendPack func(pack *Pack) error

+ type IDelegater interface

+ GetAgent func(sessionId string) (IConnAgent, error)

+ GetAgentNum func() int

+ OnDestroy func()

+ OnRpcBind func(ctx context.Context, sessionId string, userId string) (ISession, error)

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

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

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

+ OnRpcDel func(ctx context.Context, sessionId string, key string) (ISession, error)

+ OnRpcLoad func(ctx context.Context, sessionId string) (ISession, error)

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

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

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

+ OnRpcUnBind func(ctx context.Context, sessionId string) (ISession, error)

+ type IGate interface

+ GetAgentLearner func() IAgentLearner

+ GetDelegater func() IDelegater

+ GetGuestJudger func() func(session ISession) bool

+ GetRouteHandler func() RouteHandler

+ GetSendMessageHook func() SendMessageHook

+ GetSessionLearner func() ISessionLearner

+ GetStorageHandler func() StorageHandler

+ Options func() Options

+ type ISession interface

+ Clone func() ISession

+ CloneSettings func() map[string]string

+ Del func(key string) error

+ GenRPCContext func() context.Context

+ GenTraceSpan func()

+ Get func(key string) (string, bool)

+ GetIP func() string

+ GetLocalUserData func() any

+ GetNetwork func() string

+ GetServerID func() string

+ GetSessionID func() string

+ GetTraceSpan func() log.TraceSpan

+ GetUserID func() string

+ GetUserIDUint func() uint64

+ ImportSettings func(map[string]string) error

+ IsGuest func() bool

+ Set func(key, value string) error

+ SetIP func(ip string)

+ SetLocalUserData func(data any)

+ SetNetwork func(network string)

+ SetServerID func(serverId string)

+ SetSessionID func(sessionId string)

+ SetSettings func(settings map[string]string)

+ SetUserID func(userId string)

+ SettingsRange func(func(k, v string) bool)

+ ToBind func(userId string) error

+ ToClose func() error

+ ToConnected func() (bool, error)

+ ToDel func(key string) error

+ ToPush func() error

+ ToSend func(topic string, body []byte) error

+ ToSet func(key string, value string) error

+ ToSetBatch func(settings map[string]string) error

+ ToUnBind func() error

+ ToUpdate func() error

+ type ISessionLearner interface

+ Connect func(a ISession)

+ DisConnect func(a ISession)

+ type Option func(*Options)

+ func BufSize(s int) Option

+ func CertFile(s string) Option

+ func ConcurrentTasks(s int) Option

+ func EncryptKey(s string) Option

+ func HeartOverTimer(s time.Duration) Option

+ func KeyFile(s string) Option

+ func MaxPackSize(s int) Option

+ func OverTime(s time.Duration) Option

+ func SendPackBuffNum(n int) Option

+ func ServerOpts(s []server.Option) Option

+ func TCPAddr(s string) Option

+ func TLS(s bool) Option

+ func TcpAddr(s string) Option

+ func Tls(s bool) Option

+ func WsAddr(s string) Option

+ type Options struct

+ BufSize int

+ CertFile string

+ ConcurrentTasks int

+ EncryptKey string

+ HeartOverTimer time.Duration

+ KeyFile string

+ MaxPackSize int

+ Opts []server.Option

+ OverTime time.Duration

+ SendPackBuffNum int

+ TCPAddr string

+ TLS bool

+ WsAddr string

+ func NewOptions(opts ...Option) Options

+ type Pack struct

+ Body []byte

+ Topic string

+ type RouteHandler interface

+ OnRoute func(session ISession, topic string, msg []byte) (bool, error)

+ type SendMessageHook func(session ISession, topic string, msg []byte) ([]byte, error)

+ type StorageHandler interface

+ Delete func(session ISession) (err error)

+ Heartbeat func(session ISession)

+ Query func(Userid string) (data []byte, err error)

+ Storage func(session ISession) (err error)

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