Struct RateLimiter 

pub struct RateLimiter { /* private fields */ }

In-memory rate limiter that manages token buckets for different endpoints Thread-safe but not cross-process

Implementations

impl RateLimiter

pub fn new() -> Self

pub fn new_with_safety_factor(safety_factor: f64) -> Self

Create a new rate limiter with a custom safety factor Safety factor > 1.0 adds buffer time between requests For example, 1.1 means 10% longer wait times

pub fn set_safety_factor(&mut self, safety_factor: f64)

Set the safety factor for rate limiting This adds a buffer to prevent 429 errors due to timing inconsistencies

pub fn get_safety_factor(&self) -> f64

Get the current safety factor

pub async fn wait( &self, identifier: &str, rate: f64, burst: u32, ) -> Result<RateLimitGuard>

Wait for a token to become available for the given endpoint and return a guard When the guard is dropped, record_response will be called automatically

pub async fn check_token_availability(&self, identifier: &str) -> Result<bool>

Check if a token is available without consuming it

pub async fn get_token_status(&self) -> Result<HashMap<String, (f64, f64, u32)>>

Get current token status for all endpoints Returns (tokens, rate, burst) for each endpoint

pub async fn reset(&self)

Reset all rate limiting state (useful for testing)

pub async fn active_buckets_count(&self) -> usize

Get the number of active buckets

Trait Implementations

impl Default for RateLimiter

fn default() -> Self

Returns the “default value” for a type.