Struct mz_persist::retry::RetryStream

pub struct RetryStream {
    cfg: Retry,
    rng: SmallRng,
    attempt: usize,
    backoff: Option<Duration>,
}

A series of exponential, jittered, clamped sleeps.

Fields

cfg: Retry

rng: SmallRng

attempt: usize

backoff: Option<Duration>

Implementations

impl RetryStream

pub fn attempt(&self) -> usize

How many times Self::sleep has been called.

pub fn next_sleep(&self) -> Duration

The next sleep (without jitter for easy printing in logs).

pub async fn sleep(self) -> Self

Executes the next sleep in the series.

This isn’t cancel-safe, so it consumes and returns self, to prevent accidental mis-use.

fn advance(self) -> Self

Trait Implementations

impl Debug for RetryStream

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

Formats the value using the given formatter.