hub

package

v0.5.0 Latest Latest Go to latest Published: Jan 13, 2021 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

View Source

var Upgrader = websocket.Upgrader{
	ReadBufferSize:  1024,
	WriteBufferSize: 1024,
}

This section is empty.

type Client struct {
	UserId int32
	Conn   *websocket.Conn
	Hub    *Hub
	Send   chan []byte
}

func (c *Client) ReadPump()

func (c *Client) Write(mt int, payload []byte) error

func (c *Client) WritePump()

type Hub struct {
	sync.RWMutex
	Clients    map[int32]map[*Client]bool
	Broadcast  chan []byte
	Register   chan *Client
	Unregister chan *Client
}

func NewHub() *Hub

func (h *Hub) GetUserConnectionsByUserId(userId int32) map[*Client]bool

func (h *Hub) Run(ctx context.Context)