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 can never underflow past zero even if an acknowledgement 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.