Struct RetryConfig 

pub struct RetryConfig {
    pub initial: Duration,
    pub max: Duration,
    pub multiplier: f64,
    pub jitter: f64,
    pub max_attempts: u32,
}

Retry policy for batch writes. Retries rotate across healthy replicas; the sealed batch and its deduplication token are reused unchanged.

Fields

initial: Duration

First backoff delay.

max: Duration

Backoff cap.

multiplier: f64

Backoff growth factor per attempt.

jitter: f64

Fraction of the delay randomized away (0.0..=1.0).

max_attempts: u32

Total write attempts before the batch is abandoned (acknowledgements failed, watermark stalls). 0 means unbounded — retry until the drain deadline, the at-least-once default.

Trait Implementations

impl Clone for RetryConfig

fn clone(&self) -> RetryConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RetryConfig

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

Formats the value using the given formatter.

impl Default for RetryConfig

fn default() -> Self

Returns the “default value” for a type.

impl PartialEq for RetryConfig

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

impl StructuralPartialEq for RetryConfig