websocketfanout

package

v0.2.2 Latest Latest Go to latest Published: Jun 8, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Package websocketfanout provides a WebSocket presentation fanout adapter for runtime/contracts.

This section is empty.

This section is empty.

This section is empty.

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

Hub fans presentation events out to connected WebSocket clients.

func New(options ...Option) *Hub

New creates a WebSocket fanout hub.

func (hub *Hub) ClientCount() int

ClientCount returns the number of currently connected clients.

func (hub *Hub) SendPresentationEvents(ctx context.Context, events []contracts.EventEnvelope) error

SendPresentationEvents broadcasts presentation events to connected clients. Non-presentation events are ignored.

func (hub *Hub) ServeHTTP(response http.ResponseWriter, request *http.Request)

ServeHTTP upgrades one browser connection and streams presentation events.

type Option func(*Hub)

Option configures a Hub.

func WithAcceptOptions(options websocket.AcceptOptions) Option

WithAcceptOptions sets the options used for WebSocket upgrades.

func WithBufferSize(size int) Option

WithBufferSize sets each client's queued message buffer. Non-positive values keep the default.