Struct MessageQueue 

pub struct MessageQueue { /* private fields */ }

Thread-safe message queue with steering semantics.

Messages are enqueued with a SteeringMode that determines how they interact with an active run. The queue supports priority-based ordering and safe preemption at tool boundaries.

Implementations

impl MessageQueue

pub fn new(config: QueueConfig) -> Self

Create a new message queue with the given configuration.

pub fn enqueue(&self, message: QueuedMessage) -> Result<(), QueueError>

Enqueue a message. Returns error if queue is full.

pub fn remove(&self, id: &str) -> Result<QueuedMessage, QueueError>

Remove a specific queued message by ID.

pub fn status(&self) -> Result<QueueStatus, QueueError>

Get a snapshot of the current queue state.

pub fn set_active_run(&self, active: bool) -> Result<(), QueueError>

Mark that an active run has started.

pub fn has_active_run(&self) -> Result<bool, QueueError>

Whether there is an active run.

pub fn check_preemption(&self) -> Result<SteeringAction, QueueError>

Check for preemption at a tool boundary.

Inspects the queue for Interrupt or Steer messages and returns the appropriate SteeringAction. Priority: interrupt > steer.

pub fn drain_after_run(&self) -> Result<Vec<QueuedMessage>, QueueError>

Drain messages after a run completes, in priority order.

Returns messages ordered: followup first (same context), then collect (fresh runs). Collect messages within the coalesce window are batched together.

pub fn health_check(&self) -> Result<Vec<String>, QueueError>

Check queue health for heartbeat integration.

pub fn depth(&self) -> Result<usize, QueueError>

Current queue depth.

pub fn config(&self) -> &QueueConfig

Get a reference to the queue config.

Trait Implementations

impl Clone for MessageQueue

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl PreemptionCheck for MessageQueue

fn check_preemption(&self) -> Result<SteeringAction, QueueError>

Called after each tool execution completes. Returns a SteeringAction indicating what should happen next.