Struct Pacer 

pub struct Pacer { /* private fields */ }

Token Bucket Pacer

Thread-safe pacer that can be shared across async tasks.

Implementations

impl Pacer

pub fn new(initial_rate_bps: u64) -> Self

Create a new pacer with the given initial rate (bytes/sec).

pub fn unlimited() -> Self

Create an unlimited pacer (always allows sends).

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

Try to consume bytes tokens. Returns true if allowed, false if should wait.

pub fn time_until_available(&self, bytes: u64) -> Duration

How long to wait before bytes tokens are available.

pub fn set_rate(&self, rate_bps: u64)

Update the pacing rate (called by BandwidthEstimator).

pub fn rate(&self) -> u64

Get the current pacing rate (bytes/sec).

pub fn set_enabled(&self, enabled: bool)

Enable or disable pacing.

pub fn is_enabled(&self) -> bool

Whether pacing is enabled.

pub fn available_tokens(&self) -> u64

Current available tokens.

Trait Implementations

impl Debug for Pacer

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

Formats the value using the given formatter.