Struct TokenBucket 

pub struct TokenBucket {
    pub tokens: u64,
    pub max_tokens: u64,
    pub replenish_rate: u64,
    pub last_replenish: Instant,
}

Token bucket for rate limiting.

Tokens replenish over time based on replenish_rate (tokens/second). Capacity is capped at max_tokens.

Fields

tokens: u64

max_tokens: u64

replenish_rate: u64

last_replenish: Instant

Implementations

impl TokenBucket

pub fn new(max_tokens: u64, replenish_rate: u64) -> Self

pub fn replenish(&mut self, elapsed: Duration)

Replenish tokens based on elapsed time.

pub fn consume(&mut self, amount: u64)

Consume tokens if available.

pub fn try_consume(&mut self, amount: u64) -> Result<(), u64>

Try to consume tokens, returning error if insufficient.

Trait Implementations

impl Clone for TokenBucket

fn clone(&self) -> TokenBucket

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TokenBucket

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

Formats the value using the given formatter.