Struct BackpressureConfig 

pub struct BackpressureConfig {
    pub max_buffered_chunks: usize,
    pub high_watermark: f64,
    pub low_watermark: f64,
    pub strategy: BackpressureStrategy,
}

Backpressure configuration for stream processing.

Fields

max_buffered_chunks: usize

Maximum number of buffered chunks before backpressure activates.

high_watermark: f64

High watermark as a fraction of max_buffered_chunks (0.0–1.0). Backpressure activates when the buffer exceeds this fraction.

low_watermark: f64

Low watermark as a fraction (0.0–1.0). Normal processing resumes when the buffer drops below this fraction.

strategy: BackpressureStrategy

Strategy to apply when the buffer is full.

Implementations

impl BackpressureConfig

pub fn new(max_buffered: usize) -> Self

Create a new BackpressureConfig with sensible defaults. Defaults: high_watermark=0.8, low_watermark=0.2, strategy=Block.

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

Override the high and low watermark fractions.

pub fn with_strategy(self, strategy: BackpressureStrategy) -> Self

Override the backpressure strategy.

pub fn is_above_high_watermark(&self, current_buffered: usize) -> bool

Returns true when the current buffer level exceeds the high watermark.

pub fn is_below_low_watermark(&self, current_buffered: usize) -> bool

Returns true when the current buffer level is below the low watermark.

pub fn should_apply_backpressure(&self, current_buffered: usize) -> bool

Returns true when backpressure should be applied (buffer is above the high watermark).

Trait Implementations

impl Clone for BackpressureConfig

fn clone(&self) -> BackpressureConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BackpressureConfig

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

Formats the value using the given formatter.