websocket

Apr 29, 2025

Changes in this version

type WebsocketData

+ Guid string

Apr 14, 2025

Changes in this version

type SocketV1

+ func (s *SocketV1) JoinGroup(conn *WebsocketData, group string)

+ func (s *SocketV1) LeaveGroup(conn *WebsocketData, group string)

+ func (s *SocketV1) SendGroup(cmd int32, group string, req proto.Message)

type WebsocketData

+ Groups []string

Apr 14, 2025

Changes in this version

+ var Byte2Pb = make([]PbType, 0)

+ var Pb2Bytes = make([]PbType2, 0)

+ type Handler2 func(conn *WebsocketData)

+ type HandlerMessage func(conn *WebsocketData, req any)

+ type PbType func(cmd int32, data []byte, code int32, msg string) proto.Message

+ type PbType2 func(data []byte) (int, []byte)

type SocketInterface

+ Load func(serv *ghttp.Server, prefix string)

type SocketV1

+ func (s *SocketV1) BindUid(conn *WebsocketData, uid int64)

+ func (s *SocketV1) IsOnline(uid int64) bool

+ func (s *SocketV1) RegisterByte2Pb(_func PbType)

+ func (s *SocketV1) RegisterMessage(_func HandlerMessage)

+ func (s *SocketV1) RegisterPb2Byte(_func PbType2)

+ func (s *SocketV1) SendUuid(cmd int32, id uuid.UUID, req proto.Message)

+ func (s *SocketV1) Uid2Uuid(uid int64) (uuid string)

+ func (s *SocketV1) UnBindUid(uid int64)

type WebsocketData

+ RoomId int

Apr 9, 2025

Changes in this version

+ var OnCloseHandlers = make([]OnConnectHandler, 0)

+ var OnConnectHandlers = make([]OnConnectHandler, 0)

+ type OnConnectHandler func(conn *WebsocketData)

type SocketV1

+ Type int

+ func (s *SocketV1) RegisterOnClose(_func OnConnectHandler)

+ func (s *SocketV1) RegisterOnConnect(_func OnConnectHandler)

Mar 24, 2025

Changes in this version

+ type Handler func(ctx context.Context, req any) (err error)

+ type SocketInterface interface

+ OnClose func(conn *websocket.Conn)

+ OnConnect func(*websocket.Conn)

+ OnMessage func(*WebsocketData, []byte, int)

+ Send func(uuid.UUID, []byte) (err error)

+ SendAll func(data []byte)

+ type SocketV1 struct

+ func NewV1() *SocketV1

+ func (s *SocketV1) Load(serv *ghttp.Server, prefix string)

+ func (s *SocketV1) OnClose(id uuid.UUID, conn *websocket.Conn)

+ func (s *SocketV1) OnConnect(ctx context.Context, conn *websocket.Conn)

+ func (s *SocketV1) OnMessage(conn *WebsocketData, req []byte, msgType int)

+ func (s *SocketV1) RegisterRouter(cmd int, handler Handler)

+ func (s *SocketV1) Send(id uuid.UUID, data []byte) (err error)

+ func (s *SocketV1) SendAll(data []byte)

+ type WebsocketData struct

+ Ctx context.Context

+ Uid int64

+ Uuid uuid.UUID

+ Ws *websocket.Conn