Struct QueueGuardrails 

pub struct QueueGuardrails { /* private fields */ }

Queue depth tracker.

Monitors the number of pending frames and produces alerts when configured thresholds are exceeded.

Implementations

impl QueueGuardrails

pub fn new(config: QueueConfig) -> Self

Create a new queue guardrail with the given configuration.

Thresholds are normalized at construction (same policy as MemoryBudgetConfig): warn_depth is clamped to max_depth and max_depth to emergency_depth. A malformed config like warn_depth > max_depth would otherwise produce zero-excess DropOldest(0) / DropNewest(0) actions at the critical tier — alerts that look actionable but do nothing (bd-1za0z).

pub fn check( &mut self, current_depth: u32, ) -> (Option<GuardrailAlert>, QueueAction)

Report current queue depth and get an alert if thresholds are exceeded.

Returns (alert, action) where action indicates what the runtime should do about queued frames (if anything).

pub fn current_depth(&self) -> u32

Current queue depth.

pub fn peak_depth(&self) -> u32

Peak queue depth observed.

pub fn total_drops(&self) -> u64

Total frames dropped due to queue overflow.

pub fn total_backpressure_events(&self) -> u64

Total backpressure events.

pub fn config(&self) -> &QueueConfig

Get a reference to the configuration.

pub fn reset(&mut self)

Reset tracking state (preserves config).

Trait Implementations

impl Clone for QueueGuardrails

fn clone(&self) -> QueueGuardrails

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueueGuardrails

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

Formats the value using the given formatter.