Struct TokenBucket 

pub struct TokenBucket { /* private fields */ }

Token bucket for rate limiting

Implementations

impl TokenBucket

pub fn new(capacity: u64, refill_rate: u64) -> Self

Create a new token bucket

pub fn capacity(&self) -> u64

Get bucket capacity

pub fn refill_rate(&self) -> u64

Get refill rate (tokens per second)

pub fn tokens(&mut self) -> u64

Get current token count

pub fn consume(&mut self, requested: u64) -> u64

Try to consume tokens Returns the number of tokens actually consumed

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

Try to consume exactly the requested amount Returns true if successful, false if not enough tokens

pub fn wait_time(&mut self, amount: u64) -> Duration

Wait until enough tokens are available (simulated) Returns the duration to wait

pub fn reset(&mut self)

Reset bucket to full capacity

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

Update refill rate

pub fn set_capacity(&mut self, capacity: u64)

Update capacity

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

Check if bucket has enough tokens

pub fn fill_level(&mut self) -> f64

Get fill percentage (0.0 to 1.0)

Trait Implementations

impl Clone for TokenBucket

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 TokenBucket

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

Formats the value using the given formatter.