Struct SubscriberReconnectConfig 

pub struct SubscriberReconnectConfig {
    pub enabled: bool,
    pub initial_delay: Duration,
    pub retry_delay: Duration,
    pub max_delay: Duration,
    pub max_attempts: Option<usize>,
    pub dedupe_window: usize,
}

WebSocket/pubsub reconnect policy.

Reconnects are applied after an established subscription stream terminates. Initial subscription failures are still returned immediately so deployment mistakes, unsupported transports, and bad endpoints fail fast.

Fields

enabled: bool

Whether pubsub streams should be recreated after termination.

initial_delay: Duration

Delay before the first reconnect attempt.

retry_delay: Duration

Delay before the second reconnect attempt. Later retries double this delay up to Self::max_delay.

max_delay: Duration

Maximum delay between reconnect attempts.

max_attempts: Option<usize>

Maximum reconnect attempts per terminated stream. None retries forever.

dedupe_window: usize

Number of recently emitted canonical input refs remembered to suppress duplicates across reconnect backfill and subscription replay.

Trait Implementations

impl Clone for SubscriberReconnectConfig

fn clone(&self) -> SubscriberReconnectConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriberReconnectConfig

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

Formats the value using the given formatter.

impl Default for SubscriberReconnectConfig

fn default() -> Self

Returns the “default value” for a type.

impl Eq for SubscriberReconnectConfig

impl PartialEq for SubscriberReconnectConfig

fn eq(&self, other: &SubscriberReconnectConfig) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for SubscriberReconnectConfig