Struct SyncQueue 

pub struct SyncQueue { /* private fields */ }

A queue that runs jobs immediately, on the thread that dispatched them.

Not really a queue: nothing is stored and nothing is deferred. It exists so an application can be developed and tested without a worker process, which is what QUEUE_DRIVER=sync selects. A job dispatched this way fails the dispatching request if it fails, which is exactly the behaviour queueing exists to avoid — so never use it in production.

Implementations

impl SyncQueue

pub fn new(registry: Arc<JobRegistry>, container: Arc<Container>) -> Self

Run jobs inline, resolving their dependencies from container.

Trait Implementations

impl Queue for SyncQueue

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.