Struct MemoryRateLimitCounter 

pub struct MemoryRateLimitCounter { /* private fields */ }

A DashMap-backed RateLimitCounter.

Each key tracks a count and the wall-clock start of its current window; once the window elapses the count rolls over to zero on the next access. DashMap’s per-key entry lock makes the read-modify-write in increment atomic across concurrent callers. Cloning shares the same underlying map.

Implementations

impl MemoryRateLimitCounter

pub fn new() -> Self

Create an empty counter set.

Trait Implementations

impl Clone for MemoryRateLimitCounter

fn clone(&self) -> MemoryRateLimitCounter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for MemoryRateLimitCounter

fn default() -> MemoryRateLimitCounter

Returns the “default value” for a type.

impl RateLimitCounter for MemoryRateLimitCounter

fn increment<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, amount: u64, window_secs: u64, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

Atomically add amount to the counter for key within the window of length window_secs, returning the new total for the current window.

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

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

Return the current total for key without modifying it.

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

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

Reset the counter for key back to zero.