Struct TokenBucket 

pub struct TokenBucket { /* private fields */ }

A token bucket rate limiter

Implementations

impl TokenBucket

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

Create a new token bucket

Arguments

• capacity - Maximum number of tokens the bucket can hold
• fill_rate - Number of tokens added to the bucket per second

pub async fn try_acquire(&self, amount: f64) -> bool

Try to acquire tokens from the bucket

Returns true if tokens were acquired, false otherwise.

pub async fn acquire(&self, amount: f64) -> Duration

Wait until tokens are available and acquire them

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.