Struct MemoryQueue 

pub struct MemoryQueue { /* private fields */ }

An in-process queue.

Jobs live in this process’s memory, so they are lost when it stops and are invisible to any other process. Right for tests and for a single-process development server; use the database driver for anything that must survive a restart.

Implementations

impl MemoryQueue

pub fn new() -> Self

An empty queue.

pub fn failed_jobs(&self) -> Vec<FailedJob>

Every job that has exhausted its attempts.

pub fn reserved_count(&self) -> usize

How many jobs are currently reserved by a worker.

pub fn pending(&self, queue: &str) -> Vec<QueuedJob>

Every pending job on queue, available or not.

Trait Implementations

impl Debug for MemoryQueue

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

Formats the value using the given formatter.

impl Default for MemoryQueue

fn default() -> MemoryQueue

Returns the “default value” for a type.

impl Queue for MemoryQueue

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.