websocket

Documentation

Index

• func Destroy()
• func Init(opts ...InitOption)
• type ConnectionOption
  • func WithConnectionContext(context any) ConnectionOption
• type HandleCloseFunc
• type HandleConnectFunc
• type HandleDisconnectFunc
• type HandleErrorFunc
• type HandleMessageFunc
• type HandlePongFunc
• type InitOption
  • 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
• type Manager
  • 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

Functions

func Destroy

func Destroy()

func Init

func Init(opts ...InitOption)

Types

type ConnectionOption

type ConnectionOption func(sessionMap map[string]any)

func WithConnectionContext

func WithConnectionContext(context any) ConnectionOption

type HandleCloseFunc

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

type HandleConnectFunc

type HandleConnectFunc func(groupID string, context any)

type HandleDisconnectFunc

type HandleDisconnectFunc func(groupID string, context any)

type HandleErrorFunc

type HandleErrorFunc func(groupID string, err error, context any)

type HandleMessageFunc

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

type HandlePongFunc

type HandlePongFunc func(groupID string, context any)

type InitOption

type InitOption func(*InitOptions)

func InitWithConcurrentMessageHandling

func InitWithConcurrentMessageHandling(concurrentMessageHandling bool) InitOption

func InitWithMaxMessageBufferSize

func InitWithMaxMessageBufferSize(messageBufferSize int) InitOption

func InitWithMaxMessageSize

func InitWithMaxMessageSize(maxMessageSize int64) InitOption

func InitWithPingPeriodSec

func InitWithPingPeriodSec(pingPeriodSec int64) InitOption

func InitWithPongWaitSec

func InitWithPongWaitSec(pongWaitSec int64) InitOption

func InitWithWriteWaitSec

func InitWithWriteWaitSec(writeWaitSec int64) InitOption

type InitOptions

type InitOptions struct {
	// contains filtered or unexported fields
}

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

func GetInstance

func GetInstance() *Manager

func (*Manager) BroadCast

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

func (*Manager) HandleClose

func (m *Manager) HandleClose(handleCloseFunc HandleCloseFunc)

func (*Manager) HandleConnect

func (m *Manager) HandleConnect(handleConnectFunc HandleConnectFunc)

func (*Manager) HandleDisconnect

func (m *Manager) HandleDisconnect(handleDisconnectFunc HandleDisconnectFunc)

func (*Manager) HandleError

func (m *Manager) HandleError(handleErrorFunc HandleErrorFunc)

func (*Manager) HandleMessage

func (m *Manager) HandleMessage(handleMessageFunc HandleMessageFunc)

func (*Manager) HandlePong

func (m *Manager) HandlePong(handlePongFunc HandlePongFunc)

func (*Manager) HandleRequest

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