Struct mz_persist_client::internal::metrics::MetricsRetryStream

pub struct MetricsRetryStream {
    retry: RetryStream,
    pub(crate) retries: IntCounter,
    sleep_seconds: Counter,
    _finished: IncOnDrop,
}

Fields

retry: RetryStream

retries: IntCounter

sleep_seconds: Counter

_finished: IncOnDrop

Implementations

impl MetricsRetryStream

pub fn new(retry: RetryStream, metrics: &RetryMetrics) -> Self

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.