Struct InMemoryJobQueue 

pub struct InMemoryJobQueue { /* private fields */ }

Implementations

impl InMemoryJobQueue

pub fn new() -> Self

Trait Implementations

impl Default for InMemoryJobQueue

fn default() -> Self

Returns the “default value” for a type.

impl JobQueue for InMemoryJobQueue

async fn enqueue(&self, job: QueuedJob) -> Result<(), QueueError>

Enqueue a job for execution. Called by the scheduler when dependencies are met.

async fn claim( &self, worker_id: &str, worker_labels: &[String], lease_ttl: Duration, ) -> Result<Option<(QueuedJob, Lease)>, QueueError>

Atomically claim the next available job matching the worker’s labels. Returns None if no matching job is available.

async fn renew_lease( &self, lease_id: &str, extend_by: Duration, ) -> Result<(), QueueError>

Renew a lease (heartbeat). Returns error if the lease has already expired.

async fn complete( &self, lease_id: &str, outputs: HashMap<String, String>, ) -> Result<(), QueueError>

Complete a job successfully. Releases the lease and stores outputs.

async fn fail( &self, lease_id: &str, error: String, retryable: bool, ) -> Result<(), QueueError>

Fail a job. The queue decides whether to re-enqueue based on RetryPolicy.

async fn cancel( &self, workflow_id: &str, job_id: &str, ) -> Result<(), QueueError>

Cancel a specific job. If currently claimed, marks it for cancellation.

async fn cancel_workflow(&self, workflow_id: &str) -> Result<(), QueueError>

Cancel all jobs for a workflow.

async fn is_cancelled( &self, workflow_id: &str, job_id: &str, ) -> Result<bool, QueueError>

Check if a job has been marked for cancellation (workers poll this).

async fn reap_expired_leases(&self) -> Result<Vec<JobEvent>, QueueError>

Collect expired leases and emit LeaseExpired events. Called periodically by the server’s monitor task.

fn subscribe(&self) -> Receiver<JobEvent>

Subscribe to job events for event-driven processing.