Struct InMemoryRateLimiter 

pub struct InMemoryRateLimiter { /* private fields */ }

In-process per-minute limiter: buckets are keyed by "{key}:{minute}" with a 60-second window and expired buckets are pruned by periodic cleanup.

Implementations

impl InMemoryRateLimiter

pub fn new() -> Self

Creates a limiter with a 60-second window and no background cleanup task.

pub fn new_with_cleanup() -> Arc<Self>

Creates a limiter wrapped in Arc with a background task pruning expired buckets every 60s. Hold the returned Arc; the task exits when the last clone is dropped.

pub fn is_allowed_sync(&self, key: &str, limit: u32) -> bool

Synchronous check-and-increment for key against limit in the current minute bucket.

Trait Implementations

impl Default for InMemoryRateLimiter

fn default() -> Self

Returns the “default value” for a type.

impl RateLimiter for InMemoryRateLimiter

fn is_allowed<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, limit: u32, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Returns whether key may proceed under limit requests for the current minute.