realtime

Documentation

Overview

Package realtime declares the browser presentation-event realtime compiler capability and exposes dependency-free SSE helpers.

Index

• Constants
• func Addon() gowdk.Addon
• type PresentationFanout
• type SSEHub
  • func NewSSE(options ...SSEOption) *SSEHub
• type SSEOption
  • func WithSSEAudienceFromRequest(fn func(*http.Request) []string) SSEOption
  • func WithSSEBufferSize(size int) SSEOption
  • func WithSSEReplayLimit(limit int) SSEOption
  • func WithSSERetryMillis(milliseconds int) SSEOption
• type SSEStats

Constants

const ImportPath = "github.com/cssbruno/gowdk/addons/realtime"

ImportPath is the canonical Go import path for the realtime addon.

Functions

func Addon

func Addon() gowdk.Addon

Addon enables realtime presentation-event fanout support.

Types

type PresentationFanout

type PresentationFanout = contracts.PresentationFanout

PresentationFanout sends browser-facing presentation events.

type SSEHub

type SSEHub = runtimerealtime.SSEHub

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 = runtimerealtime.SSEOption

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.

func WithSSEReplayLimit

func WithSSEReplayLimit(limit int) SSEOption

WithSSEReplayLimit keeps a bounded in-memory replay buffer for browser reconnects that send Last-Event-ID.

func WithSSERetryMillis

func WithSSERetryMillis(milliseconds int) SSEOption

WithSSERetryMillis sets the browser EventSource reconnect delay advertised by the generated SSE stream.

type SSEStats

type SSEStats = runtimerealtime.SSEStats

SSEStats reports process-local SSE hub counters for app-owned metrics export.