Struct BackpressureBuffer 

pub struct BackpressureBuffer<T: Clone> {
    pub high_watermark: f64,
    pub low_watermark: f64,
    pub backpressure: bool,
    pub dropped: usize,
    /* private fields */
}

A bounded ring buffer that signals backpressure when it becomes too full.

The high_watermark fraction (e.g. 0.8) determines when backpressure is activated; the low_watermark (e.g. 0.2) determines when it is released.

Fields

high_watermark: f64

Fraction of capacity at which backpressure is asserted (0.0–1.0).

low_watermark: f64

Fraction of capacity at which backpressure is released (0.0–1.0).

backpressure: bool

Current backpressure state.

dropped: usize

Total items dropped due to backpressure.

Implementations

impl<T: Clone> BackpressureBuffer<T>

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

Create a new backpressure-aware buffer.

pub fn push(&mut self, item: T) -> bool

Try to push an item. Returns false and increments dropped if backpressure is active or the buffer is full.

pub fn pop(&mut self) -> Option<T>

Pop an item. May release backpressure if below low_watermark.

pub fn fill_fraction(&self) -> f64

Current fill fraction (0.0–1.0).

pub fn is_backpressure(&self) -> bool

Whether backpressure is currently active.

pub fn len(&self) -> usize

Number of items in the buffer.

pub fn is_empty(&self) -> bool

Is the buffer empty?

Trait Implementations

impl<T: Debug + Clone> Debug for BackpressureBuffer<T>

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

Formats the value using the given formatter.