Struct TokenBucket 

pub struct TokenBucket { /* private fields */ }

Token bucket implementation

Tracks available tokens and refills them at a constant rate. Allows bursts up to max_tokens followed by sustained usage at refill_rate.

Implementations

impl TokenBucket

pub fn new(max_tokens: f64, refill_rate: f64) -> Self

Create a new token bucket

Arguments

• max_tokens - Maximum capacity (burst size)
• refill_rate - Tokens per second refill rate

pub fn try_acquire(&mut self) -> bool

Try to consume one token, returning true if successful

pub fn remaining(&mut self) -> u32

Get the number of remaining whole tokens (after refill)

pub fn retry_after_ms(&self) -> u64

Calculate how many milliseconds until at least one token is available

pub fn reset(&mut self)

Reset the bucket to full capacity

pub fn last_access(&self) -> Instant

Return the last time this bucket was accessed (for idle detection)

Trait Implementations

impl Debug for TokenBucket

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

Formats the value using the given formatter.