Struct spoolq::Queue

pub struct Queue<T> { /* fields omitted */ }

A durable queue backed by the filesystem.

This queue stores items of type T as files in a spool directory. Files are serialized with serde_json so T must derive serde's Serialize and Deserialize traits.

The queue's directory should only contain items of the same type. Any files in the spool that fail to deserialize will be discarded.

Methods

impl<T: Serialize + Deserialize> Queue<T>

fn new(path: &str) -> Result<Queue<T>, Error>

Create a new Queue<T> using the given directory path for storage.

fn push(&mut self, item: T) -> Result<(), Error>

Push an item into the Queue.

fn pop(&self) -> Result<Option<T>, Error>

Pop an item off the queue.

This method returns the first matching directory entry. Queue ordering cannot be guaranteed to be consistent across all operating systems and filesystems, as the serialized file will be chosen based on the filesystem's directory entry ordering.

Popped items are not removed from the filesystem immediately; instead, they are marked for deletion. Use flush() to cause the items to be permanently removed from the underlying filesystem.

fn pop_filter<F>(&self, filter: F) -> Result<Option<T>, Error> where
    F: Fn(&T) -> bool, 

Pop an item off the queue matching the filter function.

This method works the same as pop(), except the item must match the given function or it is not popped off the queue.

fn drain(&self) -> Result<Vec<T>, Error>

fn flush(&self) -> Result<(), Error>

Flush removes all pending item files marked for deletion.

fn recover(&self) -> Result<(), Error>

Recover unmarks all pending item files that were previously marked for deletion.

Use recover to ensure that popped items are processed at least once, when it is uncertain whether they were processed due to a crash.

This method is only recommended if items are being processed idempotently.

Trait Implementations

impl<T: Clone> Clone for Queue<T>

fn clone(&self) -> Queue<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for Queue<T>

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.