Struct LocalWorkQueue 

pub struct LocalWorkQueue { /* private fields */ }

In-memory work queue for single-node deployments and unit tests.

All state is stored in Arc-wrapped structures so the queue can be cheaply cloned and shared across worker tasks.

Example

use stygian_graph::adapters::distributed::LocalWorkQueue;
use stygian_graph::ports::work_queue::{WorkQueuePort, WorkTask};
use serde_json::json;

let queue = LocalWorkQueue::new();
assert_eq!(queue.pending_count().await.unwrap(), 0);

let task = WorkTask {
    id: "t-1".to_string(),
    pipeline_id: "p-1".to_string(),
    node_name: "fetch".to_string(),
    input: json!({"url": "https://example.com"}),
    wave: 0,
    attempt: 0,
    idempotency_key: "ik-t1".to_string(),
};
queue.enqueue(task).await.unwrap();
assert_eq!(queue.pending_count().await.unwrap(), 1);

let dequeued = queue.try_dequeue().await.unwrap().unwrap();
assert_eq!(dequeued.node_name, "fetch");

Implementations

impl LocalWorkQueue

pub fn new() -> Self

Create a new LocalWorkQueue with default settings (max_retries = 3).

pub fn with_max_retries(max_retries: u32) -> Self

Create a LocalWorkQueue with a custom retry limit.

Example

use stygian_graph::adapters::distributed::LocalWorkQueue;

let queue = LocalWorkQueue::with_max_retries(5);

Trait Implementations

impl Clone for LocalWorkQueue

fn clone(&self) -> LocalWorkQueue

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for LocalWorkQueue

fn default() -> Self

Returns the “default value” for a type.

impl WorkQueuePort for LocalWorkQueue

fn enqueue<'life0, 'async_trait>( &'life0 self, task: WorkTask, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Enqueue a task for execution.

fn try_dequeue<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<WorkTask>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Attempt to dequeue one task. Returns None immediately if the queue is empty (non-blocking).

fn acknowledge<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, output: Value, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Acknowledge successful completion of a task.

fn fail<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, task_id: &'life1 str, error: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Record a task failure, potentially retrying or dead-lettering it.

fn status<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<TaskStatus>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieve the current TaskStatus for a task by ID.

fn collect_results<'life0, 'life1, 'async_trait>( &'life0 self, pipeline_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<(String, Value)>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Collect all completed results for a pipeline.

fn pending_count<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Number of tasks currently in the pending queue.