realtime

Documentation

Overview

Package realtime provides request-time presentation-event fanout helpers for generated apps.

Index

• type PresentationFanout
• type SSEHub
  • func NewSSE(options ...SSEOption) *SSEHub
• type SSEOption
  • func WithSSEAudienceFromRequest(fn func(*http.Request) []string) SSEOption
  • func WithSSEBufferSize(size int) SSEOption

Types

type PresentationFanout

type PresentationFanout = contracts.PresentationFanout

PresentationFanout sends browser-facing presentation events.

type SSEHub

type SSEHub = sse.Hub

SSEHub fans presentation events out to connected server-sent events clients.

func NewSSE

func NewSSE(options ...SSEOption) *SSEHub

NewSSE creates a dependency-free server-sent events presentation fanout hub.

type SSEOption

type SSEOption = sse.Option

SSEOption configures a dependency-free SSE hub.

func WithSSEAudienceFromRequest

func WithSSEAudienceFromRequest(fn func(*http.Request) []string) SSEOption

WithSSEAudienceFromRequest assigns server-owned audience labels to one SSE client. Scoped presentation events are delivered only when every event label is present in the client audience set.

func WithSSEBufferSize

func WithSSEBufferSize(size int) SSEOption

WithSSEBufferSize sets each SSE client's queued message buffer.