Struct Queue 

pub struct Queue { /* private fields */ }

Queue for managing jobs

Implementations

impl Queue

pub fn new(backend: Arc<dyn QueueBackend>) -> Self

Create a new queue with the given backend

pub fn memory() -> Self

Create a new queue backed by an in-memory backend

pub async fn enqueue(&self, job: JobWrapper) -> Result<String>

Enqueue a job and return its ID

pub async fn dequeue(&self) -> Result<Option<JobWrapper>>

Dequeue the next available job

pub async fn complete(&self, job_id: &str) -> Result<()>

Mark a job as completed

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

Mark a job as failed

pub async fn retry(&self, job: JobWrapper) -> Result<()>

Retry a job

pub async fn move_to_dead_letter(&self, job: JobWrapper) -> Result<()>

Move a job to the dead letter queue

pub async fn list_dead_letter(&self) -> Result<Vec<JobWrapper>>

List jobs in the dead letter queue

pub async fn retry_from_dead_letter(&self, job_id: &str) -> Result<()>

Retry a job from the dead letter queue

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

Clear all jobs from the queue

pub async fn get_stats(&self) -> QueueStats

Get current queue statistics