isb-apps 1.7.1

isb's apps over stacks: deployments, builds, jobs, backups, templates and notifications. Use the `isb` crate.
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
40
41

//! Retry backoff and per-channel rate limiting.

use std::collections::VecDeque;
use std::time::{Duration, Instant};

/// The longest wait between attempts (Retry-After included).
pub const BACKOFF_MAX: Duration = Duration::from_secs(300);

/// The wait before attempt `attempt + 1` (attempt counts from 1): the base
/// doubling per attempt, at least what the server asked for, capped.
pub fn backoff(base: Duration, attempt: u32, retry_after: Option<Duration>) -> Duration {
    let exp = base.saturating_mul(1u32 << attempt.saturating_sub(1).min(16));
    exp.max(retry_after.unwrap_or_default()).min(BACKOFF_MAX)
}

/// Sliding one-minute window of sends.
#[derive(Debug, Default)]
pub struct RateLimit {
    sent: VecDeque<Instant>,
}

impl RateLimit {
    /// How long to wait before the next send may go, at `now`.
    pub fn wait(&mut self, now: Instant, per_minute: usize) -> Duration {
        while self
            .sent
            .front()
            .is_some_and(|t| now.duration_since(*t) >= Duration::from_secs(60))
        {
            self.sent.pop_front();
        }
        if self.sent.len() < per_minute {
            return Duration::ZERO;
        }
        (self.sent[0] + Duration::from_secs(60)).saturating_duration_since(now)
    }

    pub fn record(&mut self, now: Instant) {
        self.sent.push_back(now);
    }
}