Struct QueueMonitor 

pub struct QueueMonitor { /* private fields */ }

Queue monitor

Implementations

impl QueueMonitor

pub fn new(queue: Arc<CommandQueue>) -> Self

Create a new queue monitor

pub fn with_config(queue: Arc<CommandQueue>, config: MonitorConfig) -> Self

Create a new queue monitor with custom configuration

pub async fn start(self: Arc<Self>)

Start monitoring

pub async fn stats(&self) -> QueueStats

Get current statistics