hub

package

v0.0.4 Latest Latest Go to latest Published: May 29, 2021 License: AGPL-3.0 Imports: 6 Imported by: 0

Details

View Source

const (
	DocAddedEvent   = "DocAdded"
	DocDeletedEvent = "DocDeleted"
)

This section is empty.

This section is empty.

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

Hub ws notificaiton hub

func NewHub() *Hub

NewHub construct a hub

func (h *Hub) ClientCount() int

ClientCount number of connected clients

func (h *Hub) ConnectWs(uid, deviceID string, connection *websocket.Conn)

ConnectWs upgrade the connection to websocket

func (h *Hub) Notify(uid, deviceID string, doc *messages.RawDocument, eventType string)

Notify sends a message to all connected clients