Struct BoundedTransferQueue 

pub struct BoundedTransferQueue { /* private fields */ }

FIFO queue of named transfers with watermark-driven admissions.

Implementations

impl BoundedTransferQueue

pub fn new(policy: BackpressurePolicy) -> Self

Creates an empty queue.

pub fn depth(&self) -> usize

Current depth.

pub fn soft_trips(&self) -> u64

Soft-limit trip count.

pub fn hard_rejects(&self) -> u64

Hard-reject count.

pub fn signal(&self) -> BackpressureSignal

Current pressure signal for depth().

pub fn try_push( &mut self, transfer: NamedTransfer, ) -> DistributeResult<BackpressureSignal>

Attempts to enqueue a transfer; hard-limit depths are rejected.

pub fn pop(&mut self) -> Option<NamedTransfer>

Pops the oldest transfer.

Trait Implementations

impl Clone for BoundedTransferQueue

fn clone(&self) -> BoundedTransferQueue

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BoundedTransferQueue

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

Formats the value using the given formatter.