Struct DefaultRateLimiterKeyed 

pub struct DefaultRateLimiterKeyed<T, K>
where
    T: RateLimitAlgorithm + Debug + Clone,
    K: Hash + Eq + Send + Sync,
{ /* private fields */ }

A keyed rate limiter that maintains separate rate limiters for each key.

Uses DashMap for efficient concurrent access to per-key rate limiters. Each key gets its own independent rate limiter instance.

Implementations

impl<T, K> DefaultRateLimiterKeyed<T, K>

where T: RateLimitAlgorithm + Debug + Clone, K: Hash + Eq + Clone + Send + Sync,

pub fn new(algorithm: T) -> Self

Create a new keyed rate limiter with the given algorithm factory function. Each key will get a fresh instance of the algorithm created by calling the factory.

pub fn active_keys(&self) -> usize

Get the number of active keys being tracked.

pub fn remove_key(&self, key: &K) -> bool

Remove a key and its associated rate limiter. Returns true if the key existed and was removed.

pub fn clear(&self)

Clear all keys and their associated rate limiters.

Trait Implementations

impl<T, K> Debug for DefaultRateLimiterKeyed<T, K>

where T: RateLimitAlgorithm + Debug + Clone + Debug, K: Hash + Eq + Send + Sync + Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T, K> RateLimiterKeyed<K> for DefaultRateLimiterKeyed<T, K>

where T: RateLimitAlgorithm + Send + Clone + Sync + Debug, K: Hash + Eq + Clone + Send + Sync,

fn acquire<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 K, ) -> Pin<Box<dyn Future<Output = Token> + Send + 'async_trait>>

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

Acquire permission to make a request for a specific key. Waits until a token is available.

fn acquire_timeout<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 K, duration: Duration, ) -> Pin<Box<dyn Future<Output = Option<Token>> + Send + 'async_trait>>

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

Acquire permission to make a request for a specific key with a timeout. Returns a token if successful.

fn release<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 K, token: Token, outcome: Option<RequestOutcome>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Release the token and record the outcome of the request for the specific key. The response time is calculated from when the token was acquired.