Struct BackpressureManager 

pub struct BackpressureManager { /* private fields */ }

Manages backpressure for a stream.

Implementations

impl BackpressureManager

pub fn new(config: BackpressureConfig, buffer_capacity: usize) -> Self

Create a new backpressure manager.

pub async fn should_apply_backpressure(&self) -> bool

Check if backpressure should be applied.

pub async fn can_release_backpressure(&self) -> bool

Check if backpressure can be released.

pub async fn handle_element_arrival(&self) -> Result<bool>

Handle a new element arrival.

pub async fn handle_element_processed(&self, latency: Duration)

Handle element processing completion.

pub async fn metrics(&self) -> LoadMetrics

Get current metrics.

pub fn set_capacity(&self, capacity: usize)

Set buffer capacity.

pub fn capacity(&self) -> usize

Get buffer capacity.

pub fn size(&self) -> usize

Get current buffer size.

pub async fn reset_metrics(&self)

Reset metrics.

pub async fn adjust_capacity_adaptive(&self)

Adaptive capacity adjustment based on load.