Struct CloudQueue 

pub struct CloudQueue { /* private fields */ }

A first-in, first-out cloud message queue.

Implementations

impl CloudQueue

pub fn new(config: CloudQueueConfig) -> Self

Create a new queue with the given configuration.

pub fn enqueue(&mut self, payload: Vec<u8>) -> Result<u64, QueueError>

Enqueue a message payload.

Returns the assigned message ID on success, or a QueueError on failure.

pub fn dequeue(&mut self) -> Result<QueueMessage, QueueError>

Dequeue and return the oldest non-expired message.

pub fn depth(&self) -> usize

Returns the current number of messages in the queue (excluding expired).

pub fn is_empty(&self) -> bool

Returns true if the queue has no messages.

Trait Implementations

impl Debug for CloudQueue

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.