Struct MemoryRateLimitStore 

pub struct MemoryRateLimitStore { /* private fields */ }

Token-bucket in-memory rate limiter.

Implementations

impl MemoryRateLimitStore

pub fn new(capacity: u32, refill_per_sec: f64) -> Self

capacity is the burst size; refill_per_sec adds tokens continuously.

Trait Implementations

impl Clone for MemoryRateLimitStore

fn clone(&self) -> MemoryRateLimitStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl RateLimitStore for MemoryRateLimitStore

fn consume<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, cost: u32, ) -> Pin<Box<dyn Future<Output = Result<RateLimitSnapshot, RateLimitSnapshot>> + Send + 'async_trait>>

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

Atomically attempts to take one permit from key’s bucket. Returns Ok(snapshot) when the request is allowed, Err(snapshot) when the caller exceeded the limit. The returned snapshot is what the caller emits in the RateLimit-* response headers.