Struct RawQueue

pub struct RawQueue { /* private fields */ }

A FIFO queue Optionally has a server side time to live

Implementations

impl RawQueue

pub async fn push(&self, data: &[u8]) -> Result<(), ErrorTypes>

enqueue a single item

pub async fn push_batch( &self, data: impl Iterator<Item = &[u8]>, ) -> Result<(), ErrorTypes>

enqueue a sequence of items

pub async fn unpop(&self, data: &[u8]) -> Result<(), ErrorTypes>

Put all messages passed back at the head of the FIFO queue.

pub async fn length(&self) -> Result<usize, ErrorTypes>

Read the number of items in the queue

pub async fn peek_next(&self) -> Result<Option<Vec<u8>>, ErrorTypes>

load the item that would be returned by the next call to pop

pub async fn content(&self) -> Result<Vec<Vec<u8>>, ErrorTypes>

Load the entire content of the queue into memory

pub async fn delete(&self) -> Result<(), ErrorTypes>

Clear all data for this object

pub async fn pop(&self) -> Result<Option<Vec<u8>>, ErrorTypes>

dequeue an item from the front of the queue, returning immediately if empty

pub async fn pop_timeout( &self, timeout: Duration, ) -> Result<Option<Vec<u8>>, ErrorTypes>

Make a blocking pop call with a timeout

pub async fn pop_batch(&self, limit: usize) -> Result<Vec<Vec<u8>>, ErrorTypes>

Pop as many items as possible up to a certain limit

pub async fn select( queues: &[&RawQueue], timeout: Option<Duration>, ) -> Result<Option<(String, Vec<u8>)>, ErrorTypes>

Wait for up to the given timeout for any of the given queues to recieve a value

Trait Implementations

impl Clone for RawQueue

fn clone(&self) -> RawQueue

Returns a copy of the value.

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

Performs copy-assignment from source.