request-rate-limiter 0.2.7

Request rate limiting with adaptive algorithms for controlling request throughput
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

use async_trait::async_trait;

use super::{RateLimitAlgorithm, RequestSample};

/// A simple, fixed request rate limit.
#[derive(Debug, Clone)]
pub struct Fixed(u64);
impl Fixed {
    #[allow(missing_docs)]
    pub fn new(rps: u64) -> Self {
        assert!(rps > 0);

        Self(rps)
    }
}

#[async_trait]
impl RateLimitAlgorithm for Fixed {
    fn requests_per_second(&self) -> u64 {
        self.0
    }

    async fn update(&self, _sample: RequestSample) -> u64 {
        self.0
    }
}