Struct AdaptiveBackpressure 

pub struct AdaptiveBackpressure { /* private fields */ }

Adaptive backpressure controller that adjusts generation rate.

Implementations

impl AdaptiveBackpressure

pub fn new() -> Self

Creates a new adaptive backpressure controller.

pub fn with_target_fill(self, target: f64) -> Self

Sets the target fill ratio.

pub fn with_delay_bounds(self, min: Duration, max: Duration) -> Self

Sets the delay bounds.

pub fn adjust(&self, current_fill: f64)

Adjusts the delay based on current fill ratio.

pub fn current_delay(&self) -> Duration

Returns the current delay to apply.

pub fn reset(&self)

Resets the delay to minimum.

Trait Implementations

impl Debug for AdaptiveBackpressure

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

Formats the value using the given formatter.

impl Default for AdaptiveBackpressure

fn default() -> Self

Returns the “default value” for a type.