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) -> Result<(), Error>

Mark job as completed.

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

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

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 release_stale( &self, stale_threshold: Duration, ) -> Result<u64, Error>

Release stale jobs back to pending.

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.