rl-core 1.18.0

Core logic for a token-bucket rate-limiter.
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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57

//! Simple, pure rate limiting.
//!
//! ```
//! const CONFIG: rl_core::Config = rl_core::Config::new(
//! 	std::time::Duration::from_secs(1),
//! 	3,
//! );
//! let mut tracker = rl_core::Tracker::full();
//! assert!(tracker.acquire(&CONFIG, 1).is_ok());
//! assert!(tracker.acquire(&CONFIG, 2).is_ok());
//! assert!(tracker.acquire(&CONFIG, 1).is_err());
//! ```

#![allow(
	clippy::tabs_in_doc_comments,
)]
#![warn(
	ambiguous_negative_literals,
	let_underscore_drop,
	missing_debug_implementations,
	missing_docs,
	single_use_lifetimes,
	trivial_casts,
	trivial_numeric_casts,
	unit_bindings,
	unused_crate_dependencies,
	unused_lifetimes,
	unused_qualifications,
	unused_results,
	variant_size_differences,
)]

mod config; pub use config::*;
mod denied; pub use denied::*;
mod too_early; pub use too_early::*;
mod tracker; pub use tracker::*;
mod tracker_time;

// These traits are currently blocked from external impls.
mod duration; pub(crate) use duration::*;
mod time; pub(crate) use time::*;
mod time_now; pub(crate) use time_now::*;

mod std_duration;
mod std_instant;
mod std_systemtime;

#[cfg(feature="serde")] mod serde;
#[cfg(feature="serde")] mod time_serde;
#[cfg(feature="serde")] pub(crate) use time_serde::*;

#[cfg(feature="tokio")] mod tokio_instant;

#[cfg(feature="serde")] #[cfg(test)] mod serde_test;

#[cfg(test)] mod tracker_test;
#[cfg(test)] mod tracker_time_test;