Struct RateLimiter 

pub struct RateLimiter { /* private fields */ }

Rate limiter for proxy transfers using a token bucket algorithm.

Implementations

impl RateLimiter

pub fn new(max_bytes_per_sec: u64) -> Self

Create a new rate limiter.

pub fn with_burst_size(self, bytes: u64) -> Self

Set the bucket capacity (burst size).

pub fn refill(&mut self, current_time_ms: u64)

Refill tokens based on elapsed time.

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

Try to consume tokens for a transfer of the given size. Returns true if the transfer is allowed.

pub fn available_tokens(&self) -> u64

Current available tokens.

pub fn max_rate(&self) -> u64

Maximum rate in bytes per second.