Struct RealtimeConfig 

pub struct RealtimeConfig {
    pub max_connections_per_context: usize,
    pub heartbeat_interval: Duration,
    pub idle_timeout: Duration,
    pub max_subscriptions_per_entity: usize,
    pub event_channel_capacity: usize,
    pub token_revalidation_interval: Duration,
    pub max_consecutive_drops: usize,
    pub connection_event_capacity: usize,
}

Configuration for the realtime WebSocket server.

Fields

max_connections_per_context: usize

Maximum concurrent connections per security context hash (default: 10).

heartbeat_interval: Duration

Interval between server heartbeat pings (default: 30s).

idle_timeout: Duration

Disconnect after this duration of inactivity (default: 60s).

max_subscriptions_per_entity: usize

Maximum subscriptions per entity across all connections (default: 10,000).

event_channel_capacity: usize

Bounded channel capacity for the observer-to-pipeline event channel (default: 10,000).

token_revalidation_interval: Duration

How often to re-validate JWT tokens (default: same as heartbeat_interval). Per D14: check JWT on each heartbeat.

max_consecutive_drops: usize

Consecutive per-connection delivery failures before kicking the client with close code 4002 “slow consumer” (default: 50).

connection_event_capacity: usize

Capacity of the per-connection event channel (default: 256).

Trait Implementations

impl Clone for RealtimeConfig

fn clone(&self) -> RealtimeConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RealtimeConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for RealtimeConfig

fn default() -> Self

Returns the “default value” for a type.