Struct BackpressureConfig 

pub struct BackpressureConfig {
    pub max_concurrent: usize,
    pub high_water_mark: f64,
    pub low_water_mark: f64,
    pub cooldown: Duration,
    pub enabled: bool,
}

Backpressure configuration.

Fields

max_concurrent: usize

Maximum concurrent operations.

high_water_mark: f64

High water mark (percentage of max_concurrent).

low_water_mark: f64

Low water mark (percentage of max_concurrent).

cooldown: Duration

Cooldown period after applying backpressure.

enabled: bool

Whether backpressure is enabled.

Implementations

impl BackpressureConfig

pub fn new() -> Self

Create new configuration.

pub fn high_threshold(&self) -> usize

Get the high water mark threshold.

pub fn low_threshold(&self) -> usize

Get the low water mark threshold.

pub fn validate(&self) -> Result<(), BackpressureError>

Validate the configuration.

Trait Implementations

impl Clone for BackpressureConfig

fn clone(&self) -> Self

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.