ws

Documentation

Index

• func NewConn(w http.ResponseWriter, r *http.Request) (conn *websocket.Conn, err error)
• type Client
  • func NewClient(hub *Hub, conn *websocket.Conn, uid string, groups []string, ...) *Client
• type Hub
  • func NewHub(fn, fu func(*Client), fb func(*Message) error) *Hub
• type Message

Functions

func NewConn

func NewConn(w http.ResponseWriter, r *http.Request) (conn *websocket.Conn, err error)

Types

type Client

type Client struct {
	Hub    *Hub
	Conn   *websocket.Conn
	Send   chan *Message
	Id     string
	Groups []string
}

func NewClient

func NewClient(hub *Hub, conn *websocket.Conn, uid string, groups []string, fr, fw func(*Client, *Message) error) *Client

type Hub

type Hub struct {
	Clients    map[string]*Client
	Broadcast  chan *Message
	Register   chan *Client
	Unregister chan *Client
}

func NewHub

func NewHub(fn, fu func(*Client), fb func(*Message) error) *Hub

type Message

type Message struct {
	Content    any      `json:"content,omitempty"`
	Sender     string   `json:"sender,omitempty"`
	Recipients []string `json:"recipients,omitempty"`
	Groups     []string `json:"groups,omitempty"`
}