ws

package

v0.0.39 Latest Latest Go to latest Published: Jan 7, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Client struct {
	Done chan struct{}
	// contains filtered or unexported fields
}

Client represents a connected websocket client

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

Hub maintains the set of active clients and broadcasts messages to them

func NewHub() *Hub

NewHub creates a new hub

func (h *Hub) BroadcastAll(message []byte)

BroadcastAll sends a message to all connected clients

func (h *Hub) BroadcastToWorkflow(workflowID string, message []byte)

func (h *Hub) NewClient(conn *websocket.Conn, workflowID string) *Client

NewClient creates a new websocket client

func (h *Hub) Run()

Run starts the hub processing loop