Struct InflightBudget 

pub struct InflightBudget { /* private fields */ }

Global in-flight byte budget, shared by pipeline threads (which add on enqueue to sink queues) and sink workers (which subtract when a batch is acknowledged or abandoned).

This is a heuristic gauge, not a synchronization point. Decisions taken on a slightly stale reading are corrected on the next poll iteration and absorbed by the controller’s hysteresis, so all operations use Ordering::Relaxed. Atomic read-modify-write operations cannot lose updates even under Relaxed (every RMW observes the latest value in the modification order); relaxation only permits stale reads in InflightBudget::usage, which the hysteresis absorbs. Both directions saturate. sub cannot underflow past zero even if an acknowledgment races ahead of the bookkeeping that added its bytes.

Implementations

impl InflightBudget

pub fn new() -> Self

An empty budget. Wrap in an Arc to share.

pub fn add(&self, bytes: usize)

Record bytes entering the in-flight window (saturating).

pub fn sub(&self, bytes: usize)

Record bytes leaving the in-flight window (saturating at zero).

pub fn usage(&self) -> usize

Current in-flight bytes (possibly slightly stale under contention).

Trait Implementations

impl Debug for InflightBudget

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

Formats the value using the given formatter.

impl Default for InflightBudget

fn default() -> InflightBudget

Returns the “default value” for a type.