Struct TokenBucket 

pub struct TokenBucket { /* private fields */ }

Token bucket rate limiter.

Tokens represent bytes. rate is bytes/second. Tokens are added via refill() (called on a timer). Burst capacity = 1 second of tokens.

Implementations

impl TokenBucket

pub fn new(rate: u64) -> Self

pub fn unlimited() -> Self

pub fn is_unlimited(&self) -> bool

pub fn rate(&self) -> u64

Current rate limit in bytes/sec (0 = unlimited).

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

Add tokens proportional to elapsed time.

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

Try to consume amount tokens. Returns true if allowed.

pub fn available(&self) -> u64

How many bytes can be consumed right now.

pub fn set_rate(&mut self, rate: u64)

Update the rate limit. Resets capacity but preserves current tokens (clamped).