Struct RateLimiter 

pub struct RateLimiter { /* private fields */ }

Concurrent per-key rate limiter.

Each API key ID gets its own [TokenBucket]. Buckets are created on first access and cleaned up when stale.

Implementations

impl RateLimiter

pub fn new(rpm: u32) -> Self

Create a new rate limiter with the given per-key requests-per-minute limit.

The refill window defaults to 60 seconds unless AA_RATE_LIMIT_WINDOW_SECS is set in the environment.

pub fn new_with_window(rpm: u32, window_secs: u64) -> Self

Create a new rate limiter with an explicit refill window.

Intended for tests that need a short window without setting an env-var.

pub fn check(&self, key_id: &str) -> Result<(), u64>

Check whether a request from the given key ID is allowed.

Returns Ok(()) if the request is within the rate limit, or Err(retry_after_secs) if the rate limit is exceeded.