Struct JobQueue 

pub struct JobQueue { /* private fields */ }

Job queue that manages job lifecycle

Implementations

impl JobQueue

pub fn new(datastore: Arc<dyn Datastore>, config: JobQueueConfig) -> Self

Create a new job queue

pub fn with_datastore(datastore: Arc<dyn Datastore>) -> Self

Create a new job queue with default configuration

pub fn register<T>(&self) -> JobResult<()>

where T: BackgroundJob + for<'de> Deserialize<'de> + Send + Sync + 'static, T::Output: Send + 'static,

Register a background job handler with the queue

This must be called for each job type before workers start processing jobs.

Example

queue.register::<MyEmailJob>()?;
queue.register::<MyReportJob>()?;

pub fn duration(&self) -> Duration

Get the lock duration for jobs

pub async fn get_job(&self, job_id: Uuid) -> JobResult<Option<Job>>

Get a job by ID

pub async fn enqueue(&self, job: Job) -> JobResult<Uuid>

Enqueue a job for execution

pub async fn claim_next_job(&self) -> JobResult<Option<Job>>

Claim the next available job for processing

pub async fn complete_job(&self, job: Job) -> JobResult<()>

Handle job completion

pub async fn fail_job(&self, job: Job, error: &str) -> JobResult<()>

Handle a job failure

pub async fn cancel_job(&self, job: Job) -> JobResult<()>

Cancel a pending or failed job

pub fn worker(&self) -> JobWorker

Create a worker for this queue

pub async fn start_worker(&self) -> JobResult<()>

Run the worker loop for this queue

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.