Skip to main content

Module queue

Module queue 

Source
Expand description

Message queue and steering semantics for concurrent message handling (Phase 2.5).

Enables safe preemption at tool boundaries, message queuing during active runs, and priority-based drain ordering: interrupt > steer > followup > collect.

Structs§

MessageQueue
Thread-safe message queue with steering semantics.
QueueConfig
Configuration for the message queue.
QueueStatus
Snapshot of the queue state for API responses.
QueuedMessage
A message waiting in the queue.

Enums§

QueueError
Errors from queue operations.
SteeringAction
Action to take at a tool boundary based on queue state.

Traits§

PreemptionCheck
Trait for checking preemption at tool boundaries.