Struct Queue

pub struct Queue<B: QueueBackend> { /* private fields */ }

High-level queue interface

Implementations

impl<B: QueueBackend> Queue<B>

pub fn new(backend: B) -> Self

Create a new queue instance with the given backend

pub async fn enqueue<T: Job>( &self, job: T, priority: Option<Priority>, ) -> QueueResult<JobId>

Enqueue a job

pub async fn enqueue_delayed<T: Job>( &self, job: T, delay: Duration, priority: Option<Priority>, ) -> QueueResult<JobId>

Enqueue a delayed job

pub async fn dequeue(&self) -> QueueResult<Option<JobEntry>>

Dequeue the next available job

pub async fn complete( &self, job_id: JobId, result: JobResult<()>, ) -> QueueResult<()>

Mark a job as completed

pub async fn get_job(&self, job_id: JobId) -> QueueResult<Option<JobEntry>>

Get job by ID

pub async fn get_jobs_by_state( &self, state: JobState, limit: Option<usize>, ) -> QueueResult<Vec<JobEntry>>

Get jobs by state

pub async fn remove_job(&self, job_id: JobId) -> QueueResult<bool>

Remove a job from the queue

pub async fn clear(&self) -> QueueResult<()>

Clear all jobs from the queue

pub async fn stats(&self) -> QueueResult<QueueStats>

Get queue statistics