Struct RateLimiter 

pub struct RateLimiter { /* private fields */ }

Token bucket rate limiter

Allows bursts up to the bucket size, then rate limits to the configured RPS.

Implementations

impl RateLimiter

pub fn new(config: RateLimitConfig) -> Self

Create a new rate limiter with the given configuration

pub async fn acquire(&self)

Acquire a token, waiting if necessary

Returns immediately if a token is available, otherwise waits until a token becomes available.

pub async fn try_acquire(&self) -> bool

Try to acquire a token without waiting

Returns true if a token was acquired, false if rate limited.

pub async fn available_tokens(&self) -> u32

Get current available tokens (for monitoring)

Trait Implementations

impl Clone for RateLimiter

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RateLimiter

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

Formats the value using the given formatter.

impl Default for RateLimiter

fn default() -> Self

Returns the “default value” for a type.