Struct CachedTokenBucket 

pub struct CachedTokenBucket { /* private fields */ }

Thread-local cached token bucket implementation

Implementations

impl CachedTokenBucket

pub fn new(capacity: u64, refill_rate_per_second: u64) -> Self

Creates a new cached token bucket

pub fn with_ttl( capacity: u64, refill_rate_per_second: u64, idle_ttl: Duration, ) -> Self

Creates a token bucket with TTL-based eviction

Trait Implementations

impl Algorithm for CachedTokenBucket

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

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

Checks if a request for the given key should be permitted.

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

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

Checks if a request with the given cost should be permitted.