Struct BackpressureController 

pub struct BackpressureController {
    pub high_watermark: usize,
    pub low_watermark: usize,
    pub current_depth: usize,
    pub throttle_events: u64,
    /* private fields */
}

Tracks backpressure between producers and consumers.

Fields

high_watermark: usize

Maximum queue depth before producer is throttled.

low_watermark: usize

Queue depth at which throttling is released.

current_depth: usize

Current queue depth.

throttle_events: u64

Total times throttling was applied.

Implementations

impl BackpressureController

pub fn new(high_watermark: usize, low_watermark: usize) -> Self

Create a backpressure controller.

pub fn enqueue(&mut self)

Record that one item was enqueued.

pub fn dequeue(&mut self)

Record that one item was dequeued.

pub fn is_throttled(&self) -> bool

Whether the producer should be throttled.

pub fn fill_ratio(&self) -> f64

Fill ratio (0.0 = empty, 1.0 = at high watermark).

pub fn reset(&mut self)

Reset depth and throttle state.