gardal 0.0.1-alpha.9

A WIP performance-focused token-bucket rate limiting and throttling 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 gardal::{FastClock, Limit, TokenBucket};
use nonzero_ext::nonzero;

fn main() {
    // Updates at 1Khz
    let _quanta_thread = quanta::Upkeep::new(Duration::from_millis(1))
        .start()
        .unwrap();
    let limit = Limit::per_second_and_burst(nonzero!(10u32), nonzero!(20u32));
    let tb = TokenBucket::with_clock(limit, FastClock);
    // after two seconds bucket should be full
    println!("sleeping for 2 seconds...");
    std::thread::sleep(Duration::from_secs(2));
    println!("available: {}", tb.available());
    assert_eq!(5, tb.consume(nonzero!(5u32)).unwrap().as_u64());
    println!("Consumed 5, available: {}", tb.available());
}