Module realtime 

Centrifugo websocket realtime client.

Structs

Client

Realtime websocket client.

SnapshotThenStream

Coordinates REST snapshot hydration with a live protobuf channel.

SnapshotThenStreamConfig

Configuration for SnapshotThenStream.

TypedSubscription

Handle for a typed protobuf realtime subscription.

Constants

MAX_REALTIME_MESSAGE_BYTES

Maximum accepted binary Centrifugo WebSocket message and frame size.

Functions

is_private_channel

try_enqueue

Enqueue a publication without blocking. On a full queue, mark the subscription closed and return Error::QueueOverflow — never silently drop.

Type Aliases

SnapshotErrorFn

Callback invoked when the coordinator observes a transport, decode, snapshot, or terminal buffer error.