Struct WorkQueue 

pub struct WorkQueue { /* private fields */ }

In-memory work queue with priority-based atomic claim.

Implementations

impl WorkQueue

pub fn new(config: WorkQueueConfig) -> Self

Create a new work queue.

pub fn enqueue( &self, work_type: impl Into<String>, payload: Value, priority: i32, ) -> String

Enqueue a new work item. Returns its ID.

pub fn claim( &self, agent_id: &str, work_type_filter: Option<&[String]>, ) -> Option<WorkItem>

Atomically claim the highest-priority pending item.

If work_type_filter is provided, only items of those types are considered. Returns None if no items are available.

pub fn start(&self, item_id: &str) -> SdkResult<()>

Transition claimed item to in-progress.

pub fn complete(&self, item_id: &str, result: WorkResult) -> SdkResult<()>

Mark item as completed with result.

pub fn retry(&self, item_id: &str) -> Result<bool>

Retry a failed item.

pub fn cancel(&self, item_id: &str) -> Result<()>

Cancel an item.

pub fn get(&self, item_id: &str) -> Option<WorkItem>

Get a work item by ID.

pub fn list(&self, filter: Option<WorkStatus>) -> Vec<WorkItem>

List items, optionally filtered by status.

pub fn stats(&self) -> WorkQueueStats

Get queue statistics.

pub fn subscribe(&self) -> Receiver<WorkEvent>

Subscribe to work events.