Struct AdvancedRateLimiter

pub struct AdvancedRateLimiter { /* private fields */ }

A more advanced rate limiter that supports different rate limiting strategies.

Implementations

impl AdvancedRateLimiter

pub fn new( requests_per_second: f64, check_every_n_seconds: f64, max_bucket_size: f64, config: RateLimiterConfig, ) -> Self

Create a new advanced rate limiter

pub async fn acquire_with_retry(&self, blocking: bool) -> Result<bool>

Acquire with retry logic and exponential backoff

pub fn config(&self) -> &RateLimiterConfig

Get the current configuration

pub fn update_config(&mut self, config: RateLimiterConfig)

Update the configuration

Trait Implementations

impl BaseRateLimiter for AdvancedRateLimiter

fn acquire(&self, blocking: bool) -> Result<bool>

Attempt to acquire the necessary tokens for the rate limiter.

fn aacquire<'life0, 'async_trait>( &'life0 self, blocking: bool, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Attempt to acquire the necessary tokens for the rate limiter. Async version.

impl Clone for AdvancedRateLimiter

fn clone(&self) -> AdvancedRateLimiter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AdvancedRateLimiter

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

Formats the value using the given formatter.