Struct CacheRateLimitLayer 

pub struct CacheRateLimitLayer { /* private fields */ }

Fixed-window counter rate limiter backed by a Cache.

Cheap to clone (everything is Arc-wrapped or Copy).

Implementations

impl CacheRateLimitLayer

pub fn new(cache: BoxedCache, capacity: u32, window: Duration) -> Self

New limiter: capacity requests per window, keyed by IP.

pub fn key_by(self, key_by: KeyBy) -> Self

pub fn key_prefix(self, prefix: impl Into<String>) -> Self

pub async fn take(&self, key: &str) -> Result<(u32, u64), u64>

Take one slot from the bucket for key. Returns Ok((current_count, reset_at_unix_secs)) on success, Err(retry_after_secs) when over capacity.

Errors

Returns Err(retry_after_secs) when the limit has been hit. Any underlying cache error is treated as “fail open” — the request is allowed and Ok((0, 0)) is returned. This avoids hard outages when Redis is briefly unreachable; flip to fail-closed by reading cache.incr(...) directly if your threat model requires it.

Trait Implementations

impl Clone for CacheRateLimitLayer

fn clone(&self) -> CacheRateLimitLayer

Returns a duplicate of the value.

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

Performs copy-assignment from source.