Struct MemoryQueue 

pub struct MemoryQueue { /* private fields */ }

A Queue in memory.

Implementations

impl MemoryQueue

pub fn new() -> Self

pub fn records(&self) -> Vec<MemoryRecord>

Every job the queue has held, in the order they were queued.

Panics

When the queue’s lock was poisoned by a panic elsewhere.

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

async fn enqueue( &self, queue: &str, payloads: Vec<Value>, ) -> Result<(), QueueError>

Queue payloads in queue, due now.

async fn enqueue_ordered( &self, queue: &str, jobs: Vec<(String, Value)>, ) -> Result<(), QueueError>

Queue jobs in queue, due now, each with its ordering key. A job is not claimed while another with the same key, queued before it in any queue, is still waiting, claimed or due to be retried; once that one is complete or failed, the next is. Jobs with different keys, and jobs with none, are claimed as they come due.

async fn claim( &self, queue: &str, limit: usize, lease: Duration, ) -> Result<Vec<Job>, QueueError>

Claim up to limit due jobs from queue for lease. None of them is claimed again until the lease lapses.

async fn complete(&self, id: &str) -> Result<(), QueueError>

A job is done; it will not be seen again.

async fn retry( &self, id: &str, delay: Duration, error: &str, ) -> Result<(), QueueError>

A job is to be tried again after delay.

async fn fail(&self, id: &str, error: &str) -> Result<(), QueueError>

A job will not be tried again.

async fn next_due(&self, queue: &str) -> Result<Option<Duration>, QueueError>

How long until the next job in queue is due, if one is waiting: how long a worker with nothing to do may sleep.