Struct QueueManager 

pub struct QueueManager { /* private fields */ }

Queue manager

Implementations

impl QueueManager

pub async fn start(&self) -> Result<()>

Start the queue scheduler

pub async fn submit( &self, lane_id: &str, command: Box<dyn Command>, ) -> Result<Receiver<Result<Value>>>

Submit a command to a lane

pub async fn stats(&self) -> Result<QueueStats>

Get queue statistics

pub fn queue(&self) -> Arc<CommandQueue>

Get the underlying command queue

pub fn subscribe(&self) -> EventStream

Subscribe to all queue lifecycle events as an EventStream (implements Stream)

pub fn subscribe_filtered( &self, filter: impl Fn(&LaneEvent) -> bool + Send + Sync + 'static, ) -> EventStream

Subscribe to filtered queue lifecycle events as an EventStream

pub async fn shutdown(&self)

Initiate graceful shutdown - stop accepting new commands

pub async fn drain(&self, timeout: Duration) -> Result<()>

Wait for all pending commands to complete (with timeout)

pub fn is_shutting_down(&self) -> bool

Check if shutdown is in progress

pub fn metrics(&self) -> Option<&QueueMetrics>

Get the metrics collector (if configured)

pub fn alerts(&self) -> Option<&Arc<AlertManager>>

Get the alert manager (if configured)