Struct AdaptiveRateLimiter 

pub struct AdaptiveRateLimiter { /* private fields */ }

Available on crate feature resilience only.

Adaptive rate limiter that backs off when receiving external rate limits.

When external services return 429 responses, this limiter reduces its throughput to avoid hammering the service.

Implementations

impl AdaptiveRateLimiter

pub fn new(rps: u32, burst_size: u32) -> Self

Create a new adaptive rate limiter.

Arguments

• rps - Base requests per second
• burst_size - Burst capacity

pub fn with_recovery_interval(self, interval: Duration) -> Self

Set the recovery interval.

pub fn with_min_rps(self, min_rps: u32) -> Self

Set the minimum RPS floor.

pub fn with_backoff_factor(self, factor: f64) -> Self

Set the backoff factor (0.0-1.0).

pub fn record_success(&self)

Record a successful request.

pub fn record_rate_limit(&self)

Record a rate limit response from an external service.

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

Check if a request is allowed.

pub async fn wait(&self)

Wait until a request is allowed.

pub fn get_status(&self) -> RateLimiterStatus

Get the current status.

pub fn external_limit_count(&self) -> u64

Get external rate limit count.