Struct FakeQueue 

pub struct FakeQueue { /* private fields */ }

A queue that records dispatches and runs nothing.

Implementations

impl FakeQueue

pub fn new() -> Self

pub fn all(&self) -> Vec<QueuedJob>

Every job pushed, in order.

pub fn pushed(&self, name: &str) -> Vec<QueuedJob>

The jobs pushed under one name — for asserting on a payload.

pub fn count(&self) -> usize

How many jobs were pushed in total.

pub fn reset(&self)

Forget everything, so one test can reuse a fake across phases.

pub fn assert_pushed(&self, name: &str) -> &Self

Assert a job with this name was dispatched at least once.

pub fn assert_pushed_times(&self, name: &str, times: usize) -> &Self

Assert a job with this name was dispatched exactly times times.

pub fn assert_not_pushed(&self, name: &str) -> &Self

Assert a job with this name was never dispatched.

pub fn assert_nothing_pushed(&self) -> &Self

Assert nothing at all was dispatched.

pub fn assert_pushed_on(&self, queue: &str, name: &str) -> &Self

Assert a job was dispatched onto a particular queue.

pub fn assert_pushed_later(&self, name: &str, delay: Duration) -> &Self

Assert a job was dispatched with a delay of at least delay.

Trait Implementations

impl Default for FakeQueue

fn default() -> Self

Returns the “default value” for a type.

impl Queue for FakeQueue

fn pop<'a>( &'a self, _queue: &'a str, ) -> BoxFuture<'a, Result<Option<ReservedJob>>>

Always empty. A fake that handed jobs back would run them, which is the one thing it exists not to do.

fn driver(&self) -> &'static str

The driver’s name. It appears in queue.* events and error messages, which is how Telescope shows which backend handled a job.

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

Store a job. Returns the driver’s identifier for it.

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

How many jobs are waiting on a queue, including delayed ones.

fn delete<'a>(&'a self, _job: &'a ReservedJob) -> BoxFuture<'a, Result<()>>

Finish with a reserved job: it succeeded and is gone.

fn release<'a>( &'a self, _job: &'a ReservedJob, _delay: Duration, ) -> BoxFuture<'a, Result<()>>

Put a reserved job back, available again after delay.

fn fail<'a>( &'a self, _job: &'a ReservedJob, _error: &'a str, ) -> BoxFuture<'a, Result<()>>

Move a reserved job to the dead-letter store with the error that killed it. It must no longer be on the queue afterwards.

fn failed_jobs(&self) -> BoxFuture<'_, Result<Vec<FailedJob>>>

Everything in the dead-letter store, oldest first.

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

Throw away every job waiting on a queue. Returns how many went.

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

Store a job on a named queue, whatever the job itself asked for.

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

Store a job that only becomes visible to a worker after delay.