Struct KeyedRateLimiter 

pub struct KeyedRateLimiter<K: Hash + Eq + Clone + Send + Sync + 'static> { /* private fields */ }

Available on crate feature resilience only.

Per-key rate limiter for limiting different resources independently.

Useful for per-endpoint, per-user, or per-API-key rate limiting.

Implementations

impl<K: Hash + Eq + Clone + Send + Sync + 'static> KeyedRateLimiter<K>

pub fn new(default_rps: u32, default_burst: u32) -> Self

Create a new keyed rate limiter with default limits.

Arguments

• default_rps - Default requests per second for new keys
• default_burst - Default burst capacity for new keys

pub fn set_limit(&self, key: K, rps: u32, burst: u32)

Set a specific limit for a key.

pub fn remove_limit(&self, key: &K)

Remove limit for a key (will use default on next access).

pub fn check(&self, key: &K) -> Result<(), RateLimitError>

Check if a request for a key is allowed.

pub async fn wait(&self, key: &K)

Wait until a request for a key is allowed.

pub fn get_status(&self, key: &K) -> Option<RateLimiterStatus>

Get status for a specific key.

pub fn get_all_status(&self) -> Vec<(K, RateLimiterStatus)>

Get all keys with their status.

pub fn clear(&self)

Clear all limiters.