Struct BandwidthThrottle 

pub struct BandwidthThrottle { /* private fields */ }

Bandwidth throttle using a token bucket algorithm.

Implementations

impl BandwidthThrottle

pub fn new(max_bytes_per_sec: usize) -> Self

pub fn set_enabled(&mut self, enabled: bool)

pub fn is_enabled(&self) -> bool

pub fn set_max_bytes_per_sec(&mut self, max: usize)

pub fn max_bytes_per_sec(&self) -> usize

pub fn refill(&mut self, now: Instant)

Refill tokens based on elapsed time.

pub fn can_send(&self, bytes: usize) -> bool

Check if we can send bytes right now.

pub fn consume(&mut self, bytes: usize)

Consume tokens for sending.

pub fn try_send(&mut self, bytes: usize, now: Instant) -> bool

Try to consume tokens; returns true if allowed.

pub fn available_bytes(&self) -> usize

pub fn utilization(&self) -> f64

pub fn reset(&mut self)