Struct DatabaseQueue 

pub struct DatabaseQueue { /* private fields */ }

A queue backed by database rows.

Implementations

impl DatabaseQueue

pub fn new(db: Database) -> Self

A database queue over db.

pub fn with_reservation(self, reservation: Duration) -> Self

How long a worker’s claim on a job lasts.

Must exceed the worker’s job timeout, or a job could be reclaimed and run twice while the first attempt is still going.

pub fn migrations() -> Migrator

The migrations this driver needs.

pub async fn reclaim_expired(&self) -> Result<u64>

Release every job whose reservation has lapsed, so a job held by a worker that died becomes available again. Returns how many.

pub async fn failed_jobs(&self, limit: u64) -> Result<Vec<FailedJobRow>>

Every failed job, newest first.

pub async fn retry_failed(&self, id: &str) -> Result<bool>

Put a failed job back on its queue for another run.

Trait Implementations

impl Debug for DatabaseQueue

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Queue for DatabaseQueue

fn name(&self) -> &str

A label for diagnostics — "database", "memory", "sync".

fn push<'a>(&'a self, job: QueuedJob) -> BoxFuture<'a, Result<String>>

Enqueue a job.

fn reserve<'a>( &'a self, queue: &'a str, ) -> BoxFuture<'a, Result<Option<QueuedJob>>>

Reserve the next available job on queue, or None if there is none.

fn acknowledge<'a>(&'a self, job: &'a QueuedJob) -> BoxFuture<'a, Result<()>>

Remove a finished job.

fn release<'a>( &'a self, job: &'a QueuedJob, delay: Duration, ) -> BoxFuture<'a, Result<()>>

Return a job to the queue for another attempt, available after delay.

fn fail<'a>( &'a self, job: &'a QueuedJob, error: &'a str, ) -> BoxFuture<'a, Result<()>>

Move a job to the failed store after its last attempt.

fn size<'a>(&'a self, queue: &'a str) -> BoxFuture<'a, Result<u64>>

How many jobs are waiting on queue.

fn clear<'a>(&'a self, queue: &'a str) -> BoxFuture<'a, Result<u64>>

Discard everything on queue. Returns how many were removed.