websocket

Jun 14, 2024

Changes in this version

+ type BroadCastFilterCallback func(context map[string]any) bool

type Manager

+ func (m *Manager) BroadCastFilter(groupID string, msg []byte, filterCallback BroadCastFilterCallback) error

Jun 13, 2024

Changes in this version

type Manager

+ func (m *Manager) RegisterHub(groupID string, opts ...InitOption)

+ func (m *Manager) UnregisterHub(groupID string)

Jun 3, 2024

Changes in this version

+ type InitOption func(*InitOptions)

+ func InitWithConcurrentMessageHandling(concurrentMessageHandling bool) InitOption

+ func InitWithMaxMessageBufferSize(messageBufferSize int) InitOption

+ func InitWithMaxMessageSize(maxMessageSize int64) InitOption

+ func InitWithPingPeriodSec(pingPeriodSec int64) InitOption

+ func InitWithPongWaitSec(pongWaitSec int64) InitOption

+ func InitWithWriteWaitSec(writeWaitSec int64) InitOption

+ type InitOptions struct

May 31, 2024

Changes in this version

+ type ConnectionOption func(sessionMap map[string]any)

+ func WithConnectionContext(context any) ConnectionOption

May 10, 2024

Changes in this version

+ func Destroy()

+ func Init()

+ type HandleCloseFunc func(groupID string, i int, s string) error

+ type HandleConnectFunc func(groupID string)

+ type HandleDisconnectFunc func(groupID string)

+ type HandleErrorFunc func(groupID string, err error)

+ type HandleMessageFunc func(groupID string, message []byte)

+ type HandlePongFunc func(groupID string)

+ type Manager struct

+ func GetInstance() *Manager

+ func (m *Manager) BroadCast(groupID string, msg []byte) error

+ func (m *Manager) HandleClose(handleCloseFunc HandleCloseFunc)

+ func (m *Manager) HandleConnect(handleConnectFunc HandleConnectFunc)

+ func (m *Manager) HandleDisconnect(handleDisconnectFunc HandleDisconnectFunc)

+ func (m *Manager) HandleError(handleErrorFunc HandleErrorFunc)

+ func (m *Manager) HandleMessage(handleMessageFunc HandleMessageFunc)

+ func (m *Manager) HandlePong(handlePongFunc HandlePongFunc)

+ func (m *Manager) HandleRequest(groupID string, w http.ResponseWriter, r *http.Request) error