Struct TokenBucket 

pub struct TokenBucket { /* private fields */ }

A token bucket for rate limiting with bursts.

Implementations

impl TokenBucket

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

Create a new token bucket.

pub fn try_consume(&self, count: usize) -> bool

Try to consume tokens.

pub async fn consume(&self, count: usize)

Consume tokens, waiting if necessary.

pub fn tokens(&self) -> usize

Get the current token count.

Trait Implementations

impl Debug for TokenBucket

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

Formats the value using the given formatter.