Struct kwait::ExponentialBackoffManager

pub struct ExponentialBackoffManager { /* fields omitted */ }

Implementations

impl ExponentialBackoffManager

pub fn new_exponential_backoff_manager(
    init_backoff: Duration,
    max_backoff: Duration,
    reset_duration: Duration,
    backoff_factor: f64,
    jitter: f64
) -> Box<dyn BackoffManager>

new_exponential_backoff_manager returns a manager for managing exponential backoff. Each backoff is jittered and backoff will not exceed the given max. If the backoff is not called within reset_duration, the backoff is reset. This backoff manager is used to reduce load during upstream unhealthiness.

Trait Implementations

impl BackoffManager for ExponentialBackoffManager

fn backoff(&mut self) -> Receiver<Instant>

Backoff implements BackoffManager.backoff, it returns a timer so caller can block on the timer for exponential backoff. The returned timer must be drained before calling backoff() the second time