Struct BackpressureConfig 

pub struct BackpressureConfig {
    pub exclusive_credits: usize,
    pub floating_credits: usize,
    pub overflow_strategy: OverflowStrategy,
    pub high_watermark: f64,
    pub low_watermark: f64,
}

Configuration for backpressure handling.

Fields

exclusive_credits: usize

Initial exclusive credits per sender (like Flink’s buffers-per-channel). These credits are always reserved for a specific sender.

floating_credits: usize

Floating credits shared across all senders (like Flink’s floating-buffers-per-gate). Allocated dynamically based on backlog priority.

overflow_strategy: OverflowStrategy

Strategy when credits are exhausted.

high_watermark: f64

High watermark - when queue reaches this %, start throttling. Value between 0.0 and 1.0.

low_watermark: f64

Low watermark - when queue drops below this %, resume normal flow. Value between 0.0 and 1.0.

Implementations

impl BackpressureConfig

pub fn builder() -> BackpressureConfigBuilder

Creates a new configuration builder.

pub fn total_credits(&self) -> usize

Total credits available (exclusive + floating).

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.

impl Default for BackpressureConfig

fn default() -> Self

Returns the “default value” for a type.