Struct BackpressureController 

pub struct BackpressureController { /* private fields */ }

Backpressure controller for automatic rate limiting

Implementations

impl BackpressureController

pub fn new(config: BackpressureConfig) -> Self

pub fn should_admit(&self) -> bool

Check if we should admit a new task

pub fn on_enqueue(&self) -> bool

Increment queue size when a task is enqueued

pub fn on_complete(&self)

Decrement queue size when a task completes

pub fn update_rate(&self, observed_latency_ms: u64)

Update throttle rate based on observed latency

pub fn current_rate(&self) -> f64

Get current throttle rate (tasks per second)

pub fn queue_size(&self) -> usize

Get current queue size

pub fn compute_delay(&self) -> Option<Duration>

Calculate delay needed before next task admission

pub fn set_max_queue_size(&self, size: usize)

Adjust max queue size dynamically

Trait Implementations

impl Debug for BackpressureController

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

Formats the value using the given formatter.

impl Default for BackpressureController

fn default() -> Self

Returns the “default value” for a type.