Struct RetryPolicy 

pub struct RetryPolicy {
    pub max_reconnect_attempts: u32,
    pub initial_backoff_ms: u64,
    pub max_backoff_ms: u64,
    pub backoff_multiplier: f64,
}

Backoff knobs applied to reconnect attempts.

Backoff progression for attempt n (1-indexed) is:

min(initial_backoff_ms * backoff_multiplier.powi(n - 1), max_backoff_ms)

Examples (defaults):

attempt 1: 500 ms
attempt 2: 1000 ms
attempt 3: 2000 ms
attempt 4: 4000 ms
attempt 5: 8000 ms
attempt 6: 16000 ms  (would be next, but capped by attempts=5)

Fields

max_reconnect_attempts: u32

Maximum number of reconnection attempts after a connection drop or heartbeat miss. 0 disables reconnection entirely (the first connect failure surfaces). Default 5.

initial_backoff_ms: u64

Delay before the first reconnect attempt, in milliseconds. Default 500.

max_backoff_ms: u64

Upper bound for any single backoff delay, in milliseconds. Must be >= initial_backoff_ms. Default 30_000 (30 seconds — matches the server-side grace window so a single backoff never exceeds the window itself).

backoff_multiplier: f64

Exponential factor applied between attempts. 2.0 doubles the delay each attempt. Must be >= 1.0; 1.0 produces constant backoff. Default 2.0.

Implementations

impl RetryPolicy

pub fn new( max_reconnect_attempts: u32, initial_backoff_ms: u64, max_backoff_ms: u64, backoff_multiplier: f64, ) -> Result<Self, Error>

Construct a validated RetryPolicy.

Returns Error::Protocol if any knob is out of range. Mirrors the Python SDK’s __post_init__ validation so an invalid policy fails loudly at construction rather than producing surprising backoff.

pub fn backoff_ms(&self, attempt: u32) -> u64

Return the delay (in ms) to wait before the given attempt.

attempt is 1-indexed: attempt = 1 is the first reconnect after a drop, attempt = 2 the second, etc. An attempt of 0 is clamped to 1 (the first backoff) — the public contract is “give me the delay for the Nth retry” and there is no zeroth retry.

Trait Implementations

impl Clone for RetryPolicy

fn clone(&self) -> RetryPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for RetryPolicy

impl Debug for RetryPolicy

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

Formats the value using the given formatter.

impl Default for RetryPolicy

fn default() -> Self

Returns the “default value” for a type.

impl PartialEq for RetryPolicy

fn eq(&self, other: &RetryPolicy) -> 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 RetryPolicy