Struct BackpressureController 

pub struct BackpressureController { /* private fields */ }

Backpressure controller for managing write queue pressure.

This controller uses atomic operations for lock-free tracking of pending frame counts. It can be shared across multiple threads/tasks.

Implementations

impl BackpressureController

pub fn new(max_pending: usize) -> Self

Create a new backpressure controller with specified limit.

pub fn with_timeout(max_pending: usize, timeout: Duration) -> Self

Create a controller with custom timeout.

pub fn from_shared( pending: Arc<AtomicUsize>, max_pending: usize, timeout: Duration, ) -> Self

Create from an existing atomic counter (for sharing with writer task).

pub fn pending_counter(&self) -> Arc<AtomicUsize>

Get a clone of the pending counter Arc (for sharing).

pub fn can_accept(&self) -> bool

Check if we can accept more frames without blocking.

pub fn is_active(&self) -> bool

Check if backpressure is currently active.

pub fn pending_count(&self) -> usize

Get current pending count.

pub fn max_pending(&self) -> usize

Get maximum pending limit.

pub fn available_capacity(&self) -> usize

Get available capacity.

pub fn try_reserve(&self) -> Result<()>

Try to reserve a slot without blocking.

Returns Ok(()) if reserved, Err(BackpressureTimeout) if at capacity.

pub async fn reserve(&self) -> Result<()>

Reserve a slot, waiting if necessary.

Returns Err(BackpressureTimeout) if timeout is reached.

pub fn release(&self)

Release a slot (called after frame is written).

pub fn release_many(&self, count: usize)

Release multiple slots at once (for batch writes).

pub fn reset(&self)

Reset the pending count (use with caution).

Trait Implementations

impl Clone for BackpressureController

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 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.