rate-net 1.0.0

A powerful, lock-free rate limiter for Rust: multiple algorithms behind one trait, sharded per-key state, bounded-memory eviction, retry-after, and a one-line Tier-1 API. Built against hostile traffic.
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

//! Awaiting until a key is allowed, instead of shedding the request.
//!
//! Requires the `async` feature:
//!
//! ```text
//! cargo run --example async_wait --features async
//! ```

use rate_net::{AsyncLimiter, RateLimiter};

#[tokio::main(flavor = "current_thread")]
async fn main() {
    // Five per second → a token refills roughly every 200ms.
    let limiter = AsyncLimiter::new(RateLimiter::per_second(5));

    // Spend the whole allowance up front.
    for _ in 0..5 {
        let _ = limiter.check("job-queue");
    }
    println!("allowance spent; awaiting a refill...");

    let start = std::time::Instant::now();
    limiter.until_ready("job-queue").await;
    println!("admitted after {:?}", start.elapsed());
}