Struct BackpressureParams 

pub struct BackpressureParams {
    pub high_bytes: usize,
    pub low_bytes: usize,
    pub min_pause: Duration,
}

Hysteresis parameters for one pipeline’s watermark controller.

Struct literals are accepted as-is for config wiring; BackpressureParams::from_budget validates its inputs. The controller assumes low_bytes <= high_bytes.

Fields

high_bytes: usize

Pause when InflightBudget::usage reaches this many bytes.

low_bytes: usize

Resume only once usage is at or below this many bytes.

min_pause: Duration

Minimum time to stay paused. Bounds the pause/resume flap rate and amortizes the prefetch purge that pausing a source implies (a paused Kafka partition drops its prefetched messages and refetches on resume — spike-verified).

Implementations

impl BackpressureParams

pub fn from_budget( max_inflight_bytes: usize, high_ratio: f64, low_ratio: f64, min_pause: Duration, ) -> BackpressureParams

Derive watermarks from a byte budget and ratios.

Panics

Panics unless max_inflight_bytes > 0 and 0.0 < low_ratio <= high_ratio <= 1.0 — these are programmer errors; user-facing validation happens at config load.

Trait Implementations

impl Clone for BackpressureParams

fn clone(&self) -> BackpressureParams

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BackpressureParams

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

Formats the value using the given formatter.

impl PartialEq for BackpressureParams

fn eq(&self, other: &BackpressureParams) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for BackpressureParams

impl Eq for BackpressureParams

impl StructuralPartialEq for BackpressureParams