Struct ExponentialBackoff 

pub struct ExponentialBackoff { /* private fields */ }

Kafka’s ExponentialBackoff: initial * multiplier^attempts, times a random factor in [1 - jitter, 1 + jitter), and never above max.

Kafka uses it with multiplier 2 and jitter 0.2 for reconnect.backoff.ms, socket.connection.setup.timeout.ms and retry.backoff.ms (ClusterConnectionStates, CommonClientConfigs).

Implementations

impl ExponentialBackoff

pub fn new(initial: Time, multiplier: u32, max: Time, jitter: f64) -> Self

Build a backoff. As in Kafka, an initial above max becomes max, and a max at or below initial turns the growth off. A jitter outside 0.0..=1.0 is clamped to that range.

pub fn kafka(initial: Time, max: Time) -> Self

Kafka’s connection and retry backoff: multiplier 2 and jitter 0.2.

pub fn backoff(&self, attempts: u32) -> Duration

The backoff after attempts failures, with a random jitter.

pub fn backoff_with(&self, attempts: u32, unit: f64) -> Duration

The backoff after attempts failures for a random value unit in [0, 1). unit 0.5 gives the backoff without jitter.

Trait Implementations

impl Clone for ExponentialBackoff

fn clone(&self) -> ExponentialBackoff

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for ExponentialBackoff

impl Debug for ExponentialBackoff

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

Formats the value using the given formatter.

impl PartialEq for ExponentialBackoff

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