Struct RateLimiter 

pub struct RateLimiter { /* private fields */ }

Token bucket rate limiter.

Tokens refill at a constant rate up to a maximum capacity. When tokens are exhausted, callers wait asynchronously.

Implementations

impl RateLimiter

pub fn new(rate: u32, burst: Option<u32>) -> Self

Create a new rate limiter.

Arguments

• rate - Sustained requests per second
• burst - Maximum burst size (default: same as rate)

pub async fn acquire(&self)

Acquire a single token, waiting asynchronously if necessary.

Returns immediately if a token is available, otherwise sleeps until enough tokens have refilled.

pub async fn try_acquire(&self) -> bool

Try to acquire a token without waiting.

Returns true if a token was available and consumed.

pub async fn available(&self) -> f64

Get the current number of available tokens (for diagnostics).

pub fn public_rest() -> Self

Create a rate limiter for public REST endpoints (50 req/s).

pub fn private_rest() -> Self

Create a rate limiter for private REST endpoints (50 req/s).

pub fn ws_order_entry() -> Self

Create a rate limiter for WebSocket order entry (20 req/s).

Trait Implementations

impl Clone for RateLimiter

fn clone(&self) -> RateLimiter

Returns a duplicate of the value.

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

Performs copy-assignment from source.