Struct BackpressureMonitor 

pub struct BackpressureMonitor { /* private fields */ }

Backpressure monitor.

Implementations

impl BackpressureMonitor

pub fn new(config: BackpressureConfig) -> Self

Create a new backpressure monitor.

pub fn with_defaults() -> Self

Create with default configuration.

pub fn config(&self) -> &BackpressureConfig

Get the configuration.

pub fn current(&self) -> usize

Get current concurrent operations.

pub fn state(&self) -> BackpressureState

Get current state.

pub fn is_active(&self) -> bool

Check if backpressure is active.

pub fn try_acquire(&self) -> bool

Try to acquire a slot for a new operation.

Returns true if the operation should proceed, false if it should be rejected.

pub fn release(&self)

Release a slot after operation completes.

pub fn total_processed(&self) -> u64

Get total processed operations.

pub fn total_rejected(&self) -> u64

Get total rejected operations.

pub fn rejection_rate(&self) -> f64

Get rejection rate.

pub fn should_apply_backpressure(&self) -> bool

Check if we should apply backpressure based on cooldown.

pub fn reset_stats(&self)

Reset statistics.