floodgate 0.5.1

A ratelimiting implementation designed for high 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
27
28
29
30

mod dynamic_mapping;
mod fixed_mapping;
mod jumping_window;
mod mapping;

pub use dynamic_mapping::DynamicMapping;
pub use fixed_mapping::FixedMapping;
pub use jumping_window::JumpingWindow;

#[cfg(test)]
mod tests {
    use std::{
        sync::Arc,
        time::{Duration, Instant},
    };

    use crate::FixedMapping;

    #[test]
    fn benchmark() {
        let mapping = Arc::new(FixedMapping::<u64>::new(1, Duration::from_secs(2)));
        FixedMapping::start(mapping.clone(), None);

        let start = Instant::now();
        for i in 0..10_000_000 {
            mapping.trigger(&i);
        }
        println!("Elapsed: {:?}", start.elapsed());
    }
}