Struct MultiQueue

pub struct MultiQueue<Message: Serialize + DeserializeOwned> { /* private fields */ }

Object represeting a colleciton of simple queues with the same prefix and message type

Implementations

impl<Message: Serialize + DeserializeOwned> MultiQueue<Message>

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

Delete one of the queues

pub async fn length(&self, name: &str) -> Result<u64, ErrorTypes>

Get the length of one of the queues

pub async fn pop_nonblocking( &self, name: &str, ) -> Result<Option<Message>, ErrorTypes>

Pop from one of the queues, returning asap if no values are available.

pub async fn pop( &self, name: &str, timeout: Duration, ) -> Result<Option<Message>, ErrorTypes>

Pop from one of the queues, wait up to timeout if no values are available.

pub async fn push( &self, name: &str, message: &Message, ) -> Result<(), ErrorTypes>

Insert an item into one of the queues