Struct RealtimeConfig 

#[non_exhaustive]
pub struct RealtimeConfig {
    pub max_concurrent_reexecutions: usize,
    pub resync_interval: DurationStr,
    pub postgres_change_buffer_size: usize,
    pub debounce_quiet_window: DurationStr,
    pub debounce_max_wait: DurationStr,
    pub sse_max_sessions: usize,
    pub subscription_max_per_session: usize,
    pub shard_count: usize,
    pub max_sessions_per_user: usize,
    pub max_sessions_per_ip: usize,
    pub max_subscriptions_per_user: usize,
    pub max_cached_result_bytes: usize,
}

Configuration for the real-time subscription engine and SSE transport.

All fields have production-safe defaults; only set these to tune behaviour.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

max_concurrent_reexecutions: usize

Maximum concurrent query re-executions during an invalidation flush.

resync_interval: DurationStr

Periodic resync interval. Re-evaluates every active query group to recover from dropped NOTIFY payloads. “0s” disables the sweep (e.g. “60s”, “5m”).

postgres_change_buffer_size: usize

Broadcast channel buffer for raw change notifications from PG.

debounce_quiet_window: DurationStr

Debounce quiet window duration. Changes arriving within this window are coalesced into a single flush (e.g. “50ms”, “100ms”).

debounce_max_wait: DurationStr

Absolute maximum debounce wait before forcing a flush (e.g. “200ms”, “1s”).

sse_max_sessions: usize

Maximum concurrent SSE sessions across all clients.

subscription_max_per_session: usize

Maximum subscriptions per SSE session.

shard_count: usize

Number of DashMap shards for the subscription manager. Higher values reduce lock contention at the cost of memory.

max_sessions_per_user: usize

Maximum concurrent SSE sessions per authenticated user.

Interacts with subscription_max_per_session and max_subscriptions_per_user: the effective per-user subscription cap is min(max_subscriptions_per_user, max_sessions_per_user * subscription_max_per_session). With defaults (10 sessions, 100 per session, 500 global), the cap is 500.

max_sessions_per_ip: usize

Maximum concurrent SSE sessions per source IP.

max_subscriptions_per_user: usize

Cap on a user’s total subscriptions across every active session.

Global per-user cap across all sessions. With max_sessions_per_user=10 and subscription_max_per_session=100, the effective per-user cap is min(500, 10*100) = 500. Lowering this below max_sessions_per_user * subscription_max_per_session enforces a tighter global ceiling regardless of how subscriptions are distributed.

max_cached_result_bytes: usize

Per-query cached-result memory ceiling (bytes). Cached results exceeding this size are dropped after re-execution.

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.

impl<'de> Deserialize<'de> for RealtimeConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for RealtimeConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.