Struct CommandQueue 

pub struct CommandQueue { /* private fields */ }

Command queue

Implementations

impl CommandQueue

pub fn new(event_emitter: EventEmitter) -> Self

Create a new command queue

pub fn with_dlq(event_emitter: EventEmitter, dlq_size: usize) -> Self

Create a new command queue with a dead letter queue

pub fn with_storage( event_emitter: EventEmitter, storage: Arc<dyn Storage>, ) -> Self

Create a new command queue with storage

pub fn with_dlq_and_storage( event_emitter: EventEmitter, dlq_size: usize, storage: Arc<dyn Storage>, ) -> Self

Create a new command queue with both DLQ and storage

pub fn storage(&self) -> Option<&Arc<dyn Storage>>

Get the storage backend

pub fn dlq(&self) -> Option<&DeadLetterQueue>

Get the dead letter queue

pub fn is_shutting_down(&self) -> bool

Check if shutdown is in progress

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 async fn register_lane(&self, lane: Arc<Lane>)

Register a lane

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 start_scheduler(self: Arc<Self>)

Start the scheduler

pub fn subscribe_stream(&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 status(&self) -> HashMap<LaneId, LaneStatus>

Get queue status for all lanes