Struct BackpressureController 

pub struct BackpressureController { /* private fields */ }

Backpressure controller for managing flow control

Implementations

impl BackpressureController

pub fn new(config: BackpressureConfig) -> Self

Create a new backpressure controller with the given configuration

pub async fn acquire(&self) -> Result<BackpressurePermit, BackpressureError>

Acquire a permit to send an item (blocks if window is full)

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

Try to acquire a permit without blocking

pub fn signal_consumed(&self)

Signal that an item has been consumed

pub fn window_size(&self) -> usize

Get current window size

pub fn items_sent(&self) -> u64

Get number of items sent

pub fn items_consumed(&self) -> u64

Get number of items consumed

pub fn pending_items(&self) -> u64

Get current pending items (sent - consumed)

pub async fn check_congestion(&self)

Check for congestion and adjust window size

pub async fn adaptive_delay(&self)

Wait if consumer is slow (adaptive delay)

pub fn start_monitoring(self: Arc<Self>) -> JoinHandle<()>

Start background task for automatic congestion monitoring

Trait Implementations

impl Clone for BackpressureController

fn clone(&self) -> BackpressureController

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for BackpressureController

fn default() -> Self

Returns the “default value” for a type.