Struct QueueConnection 

pub struct QueueConnection { /* private fields */ }

A connection to the queue backend.

Implementations

impl QueueConnection

pub async fn new(config: QueueConfig) -> Result<Self, Error>

Create a new queue connection.

pub fn config(&self) -> &QueueConfig

Get the configuration.

pub async fn push(&self, payload: JobPayload) -> Result<(), Error>

Push a job to a queue.

pub async fn pop(&self, queue: &str) -> Result<Option<JobPayload>, Error>

Pop a job from a queue (blocking).

pub async fn pop_nowait(&self, queue: &str) -> Result<Option<JobPayload>, Error>

Pop a job from a queue (non-blocking).

pub async fn migrate_delayed(&self, queue: &str) -> Result<usize, Error>

Move delayed jobs that are ready to the main queue.

pub async fn release( &self, payload: JobPayload, delay: Duration, ) -> Result<(), Error>

Release a job back to the queue (for retry).

pub async fn fail( &self, payload: JobPayload, error: &Error, ) -> Result<(), Error>

Mark a job as failed.

pub async fn size(&self, queue: &str) -> Result<usize, Error>

Get the number of jobs in a queue.

pub async fn delayed_size(&self, queue: &str) -> Result<usize, Error>

Get the number of delayed jobs in a queue.

pub async fn clear(&self, queue: &str) -> Result<(), Error>

Clear all jobs from a queue.

pub async fn get_pending_jobs( &self, queue: &str, limit: usize, ) -> Result<Vec<JobInfo>, Error>

Get pending jobs from a queue (without removing them).

pub async fn get_delayed_jobs( &self, queue: &str, limit: usize, ) -> Result<Vec<JobInfo>, Error>

Get delayed jobs from a queue (without removing them).

pub async fn get_failed_jobs( &self, limit: usize, ) -> Result<Vec<FailedJobInfo>, Error>

Get failed jobs (without removing them).

pub async fn failed_count(&self) -> Result<usize, Error>

Get the count of failed jobs.

pub async fn get_stats(&self, queues: &[&str]) -> Result<QueueStats, Error>

Get queue statistics for specified queues.

Trait Implementations

impl Clone for QueueConnection

fn clone(&self) -> QueueConnection

Returns a duplicate of the value.

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

Performs copy-assignment from source.