Struct StandardRateLimiter 

pub struct StandardRateLimiter { /* private fields */ }

Standard rate limiter using token bucket

Implementations

impl StandardRateLimiter

pub fn new( storage: Arc<dyn StorageProvider>, default_rpm: u32, burst_capacity: u32, ) -> Self

Trait Implementations

impl RateLimiter for StandardRateLimiter

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

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

Check if request is allowed

fn record_request<'life0, 'life1, 'async_trait>( &'life0 self, _key: &'life1 RateLimitKey, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Record request for rate limiting

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

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

Apply penalty for threats

fn get_stats(&self) -> RateLimiterStats

Get rate limit stats