Struct RateLimiter 

pub struct RateLimiter { /* private fields */ }

Available on crate feature resilience only.

Token bucket rate limiter.

Allows a sustained rate of requests with burst capacity.

Implementations

impl RateLimiter

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

Create a new rate limiter.

Arguments

• rps - Maximum requests per second
• burst_size - Additional burst capacity above the sustained rate

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

Check if a request is allowed without blocking.

Returns Ok(()) if allowed, Err(RateLimitError) if rate limited.

pub async fn wait(&self)

Wait until a request is allowed.

Blocks the current task until the rate limit permits the request.

pub fn get_status(&self) -> RateLimiterStatus

Get the current status of the rate limiter.