Struct AdaptiveRateLimiter 

pub struct AdaptiveRateLimiter { /* private fields */ }

Adaptive rate limiter that adjusts based on provider responses

Implementations

impl AdaptiveRateLimiter

pub fn new(base_delay_ms: u64) -> Self

Create a new adaptive rate limiter

pub async fn current_delay(&self) -> Duration

Get the current delay

pub async fn record_success(&self, headers: Option<&HashMap<String, String>>)

Record a successful request with optional rate limit headers

pub async fn record_rate_limit_hit(&self, retry_after: Option<u64>)

Record a rate limit hit (429 response)

pub async fn record_retry(&self)

Record a retry attempt

pub async fn get_stats(&self) -> RateLimitStats

Get current statistics

pub async fn get_rate_limit_info(&self) -> RateLimitInfo

Get current rate limit info

pub async fn wait(&self)

Wait for the appropriate delay before making next request

pub async fn reset(&self)

Reset the rate limiter to initial state

Trait Implementations

impl Clone for AdaptiveRateLimiter

fn clone(&self) -> AdaptiveRateLimiter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AdaptiveRateLimiter

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

Formats the value using the given formatter.

impl Default for AdaptiveRateLimiter

fn default() -> Self

Returns the “default value” for a type.