Struct JobQueue 

pub struct JobQueue { /* private fields */ }

Job queue operations.

Implementations

impl JobQueue

pub fn new(pool: PgPool) -> Self

Create a new job queue.

pub async fn enqueue(&self, job: JobRecord) -> Result<Uuid, Error>

Enqueue a new job.

pub async fn claim( &self, worker_id: Uuid, capabilities: &[String], limit: i32, ) -> Result<Vec<JobRecord>, Error>

Claim jobs using SKIP LOCKED pattern.

pub async fn start(&self, job_id: Uuid) -> Result<(), Error>

Mark job as running.

pub async fn complete( &self, job_id: Uuid, output: Value, ttl: Option<Duration>, ) -> Result<(), Error>

Mark job as completed.

If ttl is provided, sets expires_at for automatic cleanup.

pub async fn fail( &self, job_id: Uuid, error: &str, retry_delay: Option<Duration>, ttl: Option<Duration>, ) -> Result<(), Error>

Mark job as failed, schedule retry or move to dead letter.

If ttl is provided and job moves to dead_letter, sets expires_at for automatic cleanup.

pub async fn heartbeat(&self, job_id: Uuid) -> Result<(), Error>

Update heartbeat for a running job.

pub async fn update_progress( &self, job_id: Uuid, percent: i32, message: &str, ) -> Result<(), Error>

Update job progress.

pub async fn set_context( &self, job_id: Uuid, context: Value, ) -> Result<(), Error>

Replace persisted job context.

pub async fn request_cancel( &self, job_id: Uuid, reason: Option<&str>, ) -> Result<bool, Error>

Request cancellation for a job.

pub async fn cancel( &self, job_id: Uuid, reason: Option<&str>, ttl: Option<Duration>, ) -> Result<(), Error>

Mark job as cancelled.

If ttl is provided, sets expires_at for automatic cleanup.

pub async fn release_stale( &self, stale_threshold: Duration, ) -> Result<u64, Error>

Release stale jobs back to pending.

pub async fn cleanup_expired(&self) -> Result<u64, Error>

Delete expired job records.

Only deletes terminal jobs (completed, cancelled, failed, dead_letter) that have passed their TTL.

pub async fn stats(&self) -> Result<QueueStats, Error>

Get queue statistics.

Trait Implementations

impl Clone for JobQueue

fn clone(&self) -> JobQueue

Returns a duplicate of the value.

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

Performs copy-assignment from source.