Struct ReconnectBackoff 

pub struct ReconnectBackoff { /* private fields */ }

Validated reconnect backoff settings drawn from WorkerConfig.

Implementations

impl ReconnectBackoff

pub fn from_config(config: &WorkerConfig) -> Result<Self, WorkerError>

Builds reconnect backoff from worker config.

Errors

Returns WorkerError::Registration if delays or attempt counts are zero.

pub fn delay_for_attempt(&self, completed_failures: usize) -> Duration

Returns the bounded exponential delay after completed_failures failures.

The delay doubles per completed failure starting from the configured initial backoff and is capped at the configured maximum backoff.

pub const fn attempts(&self) -> usize

Returns the configured maximum number of reconnect attempts.

pub const fn max_delay(&self) -> Duration

Returns the configured maximum backoff delay cap.

The run loop also uses this as its session-health threshold: the cap is the policy’s own definition of the longest pause, so an established session that survives longer than it is demonstrably past the flapping regime and resets the cumulative drop budget when it eventually drops.

Trait Implementations

impl Clone for ReconnectBackoff

fn clone(&self) -> ReconnectBackoff

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReconnectBackoff

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

Formats the value using the given formatter.

impl Eq for ReconnectBackoff

impl PartialEq for ReconnectBackoff

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