speedbump 0.1.0

An extensible rate limiting library.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use std::time::Duration;

use speedbump::{Limiter, store::memory::MemoryStore, strategy::FixedWindow};

#[tokio::main]
async fn main() {
    let fixed_window = FixedWindow::new(Duration::from_secs(10), 10);

    let store = MemoryStore::new();
    let limiter = Limiter::builder()
        .store(store)
        .strategy(fixed_window)
        .build();

    for iteration in 0..20 {
        let allowed = limiter.limit("test").await.expect("limit checking failed");
        println!("Iteration {:?}, allowed: {}", iteration, allowed);
    }
}