async_repeat 0.1.0

Retry futures mechanism
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
37
38
39

use crate::{RetryStrategy, TooManyAttempts};
use std::time::Duration;

pub struct LinearRetryStrategy {
    pub max_attempts: usize,
    pub delay_between_repeats: Duration,
}

impl Default for LinearRetryStrategy {
    fn default() -> Self {
        Self { max_attempts: 5, delay_between_repeats: Duration::from_millis(500) }
    }
}

impl RetryStrategy for LinearRetryStrategy {
    fn check_attempt(&mut self, attempts_before: usize) -> Result<Duration, TooManyAttempts> {
        if self.max_attempts == attempts_before {
            Err(TooManyAttempts)
        } else {
            Ok(self.delay_between_repeats)
        }
    }
}

impl LinearRetryStrategy {
    pub fn new() -> Self {
        Self::default()
    }

    pub fn max_attempts(mut self, max_attempts: usize) -> Self {
        self.max_attempts = max_attempts;
        self
    }

    pub fn delay_between_repeats(mut self, delay_between_repeats: Duration) -> Self {
        self.delay_between_repeats = delay_between_repeats;
        self
    }
}