Struct QueueDepthTracker 

pub struct QueueDepthTracker { /* private fields */ }

Request queue depth tracker.

Thread-safe counter for tracking how many requests are currently queued or in-flight. Used to implement backpressure.

Implementations

impl QueueDepthTracker

pub fn new(max_depth: usize) -> Self

Create a new tracker with the given maximum depth.

pub fn try_acquire(&self) -> bool

Try to acquire a slot. Returns true if successful, false if queue is full.

pub fn release(&self)

Release a slot.

pub fn depth(&self) -> usize

Current queue depth.

pub fn max_depth(&self) -> usize

Maximum allowed depth.

pub fn has_capacity(&self) -> bool

Whether the queue has capacity for more requests.