websocket

Feb 6, 2025

Changes in this version

+ const ConnUUIDCTXKey

+ type BaseTextMessageController struct

+ Action string

+ ActionParams map[string]interface{}

+ Client *Client

+ func (b *BaseTextMessageController) Init(_ TextMessageController)

+ func (b *BaseTextMessageController) ParsePayload(_ context.Context, client *Client, message ReceiveMessage) (err error)

+ type Client struct

+ State State

+ UserId int64

+ func NewClient(conn *websocket.Conn, uuidStr string, userId int64) *Client

+ func (c *Client) WriteTextMessage(ctx context.Context, message []byte) (err error)

+ type ClientManager struct

+ func NewClientManager() *ClientManager

+ func (m *ClientManager) Delete(uuid string)

+ func (m *ClientManager) IsExist(uuid string) bool

+ func (m *ClientManager) Len() int

+ func (m *ClientManager) Range(f func(key, value any) bool)

+ func (m *ClientManager) Store(uuid string, c *Client)

+ type Config struct

+ AllowedOrigins []string

+ EnableCompression bool

+ HandshakeTimeoutSec time.Duration

+ ReadBufferSize int

+ WriteBufferPool int

+ WriteBufferSize int

+ type ReceiveMessage struct

+ Action string

+ ActionParams map[string]interface{}

+ SID string

+ Scene string

+ SceneParams map[string]interface{}

+ type RedisPubSub struct

+ func NewRedisPubSub(channels ...string) *RedisPubSub

+ func (r *RedisPubSub) Publish(ctx context.Context, redisClient *redis.Client, msg any) *redis.IntCmd

+ func (r *RedisPubSub) Subscribe(ctx context.Context, redisClient *redis.Client, ...) error

+ type State struct

+ SID string

+ Scene string

+ SceneParams map[string]interface{}

+ type TextMessageController interface

+ Init func(base TextMessageController)

+ ParsePayload func(ctx context.Context, c *Client, message ReceiveMessage) error

+ Process func(ctx context.Context) error

+ type WebSocket struct

+ func New(configPath string) *WebSocket

+ func (ws *WebSocket) GetClientManager() *ClientManager

+ func (ws *WebSocket) Handle(ctx context.Context, path string, r *http.Request, w http.ResponseWriter)

+ func (ws *WebSocket) OnTextMessageController(scene string, controller TextMessageController)

+ func (ws *WebSocket) SetAuthorizationFunc(...)

+ func (ws *WebSocket) SetBeforeFunc(...)

+ func (ws *WebSocket) SetClientCloseFunc(f func(context.Context, string))