Struct SendThrottle 

pub struct SendThrottle { /* private fields */ }

Per-mirror send throttle shared between the sender task and the ack handler.

Clone-cheap: backed by Arc<AtomicU64>.

Implementations

impl SendThrottle

pub fn new(cap: u64) -> Self

Create a new throttle with the given cap.

pub fn default_cap() -> Self

Create a throttle with DEFAULT_CAP_BYTES.

pub fn in_flight(&self) -> u64

Current bytes in flight (approximate, relaxed ordering).

pub fn can_send(&self) -> bool

Whether the source should currently send to this mirror.

Returns true when in_flight < cap.

pub fn can_resume(&self) -> bool

Whether the source may resume after being throttled.

Returns true when in_flight <= resume_threshold.

pub fn charge(&self, bytes: u64)

Record that bytes have been dispatched toward the mirror.

Call this before writing a chunk to the QUIC stream.

pub fn ack(&self, bytes: u64)

Record that bytes have been acknowledged by the mirror.

Saturates at zero to guard against double-acks.

pub fn reset(&self)

Reset the counter to zero (called on link teardown).

pub fn cap(&self) -> u64

The configured cap in bytes.

Trait Implementations

impl Clone for SendThrottle

fn clone(&self) -> SendThrottle

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SendThrottle

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

Formats the value using the given formatter.