Struct Queue 

pub struct Queue { /* private fields */ }

Job queue backed by Redis.

Implementations

impl Queue

pub async fn new( redis_url: impl Into<String>, queue_name: impl Into<String>, ) -> QueueResult<Self>

Create a new queue.

pub async fn with_config(config: QueueConfig) -> QueueResult<Self>

Create a queue with custom configuration.

pub async fn enqueue( &self, job_type: impl Into<String>, data: JobData, ) -> QueueResult<JobId>

Enqueue a job.

pub async fn enqueue_job(&self, job: Job) -> QueueResult<JobId>

Enqueue a job with options.

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

Dequeue the next job.

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

Complete a job.

pub async fn fail(&self, job_id: JobId, error: String) -> QueueResult<()>

Fail a job.

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

Get a job by ID.

pub async fn size(&self) -> QueueResult<usize>

Get queue size.

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

Clear all jobs from the queue.

Trait Implementations

impl Clone for Queue

fn clone(&self) -> Queue

Returns a duplicate of the value.

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

Performs copy-assignment from source.