ws_hub

Documentation

Index

• type WsConnection
  • func (conn *WsConnection) WriterLoop()
• type WsHub
  • func New() *WsHub
  • func Run() *WsHub
  • func (hub *WsHub) RegisterConn(wsConn *websocket.Conn) *WsConnection
  • func (hub *WsHub) SendMsg(msg []byte)
  • func (hub *WsHub) UnregisterConn(conn *WsConnection)

Types

type WsConnection

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

WebSocket connection

func (*WsConnection) WriterLoop

func (conn *WsConnection) WriterLoop()

Write loop

type WsHub

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

WebSocket connections hub

func New

func New() *WsHub

Instanciates a new WebSocket hub

func Run

func Run() *WsHub

Instanciates a new WebSocket hub and run it

func (*WsHub) RegisterConn

func (hub *WsHub) RegisterConn(wsConn *websocket.Conn) *WsConnection

Register a new WebSocket connection

func (*WsHub) SendMsg

func (hub *WsHub) SendMsg(msg []byte)

Broadcast message to all registered WebSocket connections

func (*WsHub) UnregisterConn

func (hub *WsHub) UnregisterConn(conn *WsConnection)

Unregister a WebSocket connection