Struct BackpressureMonitor 

pub struct BackpressureMonitor { /* private fields */ }

Monitors and reports backpressure conditions.

Implementations

impl BackpressureMonitor

pub fn new(strategy: BackpressureStrategy, capacity: usize) -> Self

Creates a new backpressure monitor.

pub fn with_watermarks(self, high: f64, low: f64) -> Self

Creates a monitor with custom watermarks.

pub fn update_fill(&self, current: usize)

Updates the current fill level.

pub fn fill_ratio(&self) -> f64

Returns the current fill ratio (0.0 to 1.0+).

pub fn should_apply_backpressure(&self) -> bool

Returns whether backpressure should be applied.

pub fn has_recovered(&self) -> bool

Returns whether the system has recovered from backpressure.

pub fn record_backpressure(&self)

Records a backpressure event.

pub fn record_dropped(&self, count: u64)

Records dropped items.

pub fn record_blocked_time(&self, duration: Duration)

Records blocked time.

pub fn stats(&self) -> BackpressureStats

Returns backpressure statistics.

pub fn strategy(&self) -> BackpressureStrategy

Returns the configured strategy.

Trait Implementations

impl Debug for BackpressureMonitor

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

Formats the value using the given formatter.