notification

Documentation

Index

• type Hub
  • func NewHub(ctx context.Context) *Hub
  • func (h *Hub) AcceptConnection(ws *websocket.Conn)
  • func (h *Hub) Broadcast(msg string)

Types

type Hub

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

Hub is a hub of websocket connections. Those connections are connected to each other via this hub.

func NewHub

func NewHub(ctx context.Context) *Hub

NewHub returns a new hub which is accepting notifications and connections. The hub stops accepting new requests when "ctx" is canceled.

func (*Hub) AcceptConnection

func (h *Hub) AcceptConnection(ws *websocket.Conn)

AcceptConnection receives a websocket connection and register it as a subscriber of broadcast notifications.

func (*Hub) Broadcast

func (h *Hub) Broadcast(msg string)

Broadcast sends "msg" to the registered connections.