Struct QueueClient 

pub struct QueueClient<'a> { /* private fields */ }

Implementations

impl<'a> QueueClient<'a>

pub async fn create(&self, queue: &str) -> Result<QueryResult>

pub async fn push( &self, queue: &str, value: &JsonValue, options: QueuePushOptions, ) -> Result<QueryResult>

pub async fn peek(&self, queue: &str, limit: Option<u64>) -> Result<ListResult>

pub async fn pop(&self, queue: &str) -> Result<ListResult>

pub async fn len(&self, queue: &str) -> Result<u64>

pub async fn purge(&self, queue: &str) -> Result<DeleteResult>

pub async fn read_wait( &self, queue: &str, consumer: &str, wait: Duration, opts: QueueReadWaitOptions<'_>, ) -> Result<ListResult>

QUEUE READ … WAIT <wait> — block until a message is available for consumer on queue (optionally scoped to group), the wait budget elapses, or the server cancels.

Timeout returns an empty ListResult — the same shape an empty non-waiting read would produce — never an error. Cancellation and cap rejection surface as ClientErrors from the underlying transport (PRD #718 slice C). wait must be specified — there is no infinite-wait default.

Trait Implementations

impl<'a> Debug for QueueClient<'a>

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

Formats the value using the given formatter.