ws

package

v0.1.0 Latest Latest Go to latest Published: Apr 14, 2026 License: MIT Imports: 9 Imported by: 0

Details

Package ws implements a WebSocket hub that bridges the internal event bus to connected clients (both browser and service consumers).

This section is empty.

This section is empty.

This section is empty.

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

Hub manages connected WebSocket clients and fans events out to them.

func NewHub(logger *slog.Logger, apiKey []byte) *Hub

NewHub creates a Hub that broadcasts events to connected WebSocket clients.

func (h *Hub) HandleEvent(_ context.Context, e events.Event)

HandleEvent implements events.Handler. It marshals the event to JSON and delivers it to every connected client.

func (h *Hub) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP upgrades the connection to WebSocket and starts pumping events.