Struct BackpressureController 

pub struct BackpressureController { /* private fields */ }

Adaptive backpressure controller implementing multiple mitigation strategies.

Implementations

impl BackpressureController

pub fn new(config: BackpressureConfig) -> Self

Create a new controller with the supplied configuration.

pub fn try_accept(&mut self, now_ms: u64) -> BackpressureDecision

Attempt to accept one item at now_ms (monotonic milliseconds).

Updates internal state and returns the decision the caller should act on.

pub fn record_dequeue(&mut self)

Record that one item was consumed from the queue.

pub fn stats(&self) -> &BackpressureStats

Return a reference to the current statistics.

pub fn reset_stats(&mut self)

Reset all counters (peak_queue_depth, items_dropped, …) without changing the queue depth or backpressure state.

pub fn is_above_high_watermark(&self) -> bool

Return true when the current depth is at or above the high watermark.

pub fn is_below_low_watermark(&self) -> bool

Return true when the current depth is at or below the low watermark.

pub fn replenish_tokens(&mut self, now_ms: u64)

Replenish the token bucket based on elapsed time since the last tick.

Only effective when the strategy is Throttle.

pub fn current_depth(&self) -> usize

Return the current logical queue depth.

Trait Implementations

impl Debug for BackpressureController

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

Formats the value using the given formatter.