streambed 0.13.0

Streambed core library components
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

// A utility for delaying with exponential backoff. Once retries have
// been attained then we start again. There are a hard set of values
// here as it is private within Streambed.

use std::time::Duration;

use exponential_backoff::Backoff;
use tokio::time;

pub struct Delayer {
    backoff: Backoff,
    retry_attempt: u32,
}

impl Delayer {
    pub async fn delay(&mut self) {
        let delay = if let Some(d) = self.backoff.next(self.retry_attempt) {
            d
        } else {
            self.retry_attempt = 0;
            self.backoff.next(self.retry_attempt).unwrap()
        };
        time::sleep(delay).await;
        self.retry_attempt = self.retry_attempt.wrapping_add(1);
    }
}

impl Default for Delayer {
    fn default() -> Self {
        let backoff = Backoff::new(8, Duration::from_millis(100), Duration::from_secs(10));
        Self {
            backoff,
            retry_attempt: 0,
        }
    }
}