Struct QueueMonitor 

pub struct QueueMonitor {
    pub warning_threshold: f64,
    pub critical_threshold: f64,
}

Monitor for queue health and utilization.

Provides real-time health checking for message queues without dynamic resizing, allowing applications to take action when queues approach capacity.

Example

use ringkernel_core::queue::{QueueMonitor, SpscQueue, QueueHealth};

let queue = SpscQueue::new(1024);
let monitor = QueueMonitor::default();

// Check health periodically
match monitor.check(&queue) {
    QueueHealth::Healthy => { /* normal operation */ }
    QueueHealth::Warning => { /* consider throttling producers */ }
    QueueHealth::Critical => { /* alert! take immediate action */ }
}

Fields

warning_threshold: f64

Utilization threshold for warning (0.0 - 1.0).

critical_threshold: f64

Utilization threshold for critical (0.0 - 1.0).

Implementations

impl QueueMonitor

pub fn new(warning_threshold: f64, critical_threshold: f64) -> QueueMonitor

Create a new queue monitor with custom thresholds.

pub fn check(&self, queue: &dyn MessageQueue) -> QueueHealth

Check the health of a queue.

pub fn utilization(&self, queue: &dyn MessageQueue) -> f64

Get the current utilization (0.0 - 1.0).

pub fn utilization_percent(&self, queue: &dyn MessageQueue) -> f64

Get current utilization percentage.

pub fn suggest_upgrade( &self, queue: &dyn MessageQueue, current_tier: QueueTier, ) -> Option<QueueTier>

Suggest whether to upgrade the queue tier based on observed utilization.

Returns Some(QueueTier) if upgrade is recommended, None otherwise.

pub fn has_drops(&self, queue: &dyn MessageQueue) -> bool

Check if queue has experienced drops.

pub fn drop_rate(&self, queue: &dyn MessageQueue) -> f64

Get the drop rate (drops / total attempted enqueues).

Trait Implementations

impl Clone for QueueMonitor

fn clone(&self) -> QueueMonitor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueueMonitor

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

Formats the value using the given formatter.

impl Default for QueueMonitor

fn default() -> QueueMonitor

Returns the “default value” for a type.