Struct QueuesClient 

pub struct QueuesClient { /* private fields */ }

Queues module client.

Implementations

impl QueuesClient

pub async fn acquire( &self, topic: impl Into<String>, group: impl Into<String>, options: AcquireOptions, ) -> Result<QueueAcquireResult, KrabkaError>

Acquire queue messages.

Errors

Returns an error for invalid queue options, transport failures, or a gateway request error.

pub async fn acquire_with_session( &self, topic: impl Into<String>, group: impl Into<String>, options: AcquireOptions, session_id: impl Into<String>, ) -> Result<QueueAcquireResult, KrabkaError>

Acquire queue messages, optionally reusing a gateway session.

Errors

Returns an error for invalid queue options, transport failures, or a gateway request error.

pub async fn acknowledge( &self, session_id: impl Into<String>, entries: Vec<QueueAckEntry>, ) -> Result<Vec<QueueAckResult>, KrabkaError>

Acknowledge queue messages.

Errors

Returns an error when the session is invalid or the gateway request fails. Per-entry failures are returned in the result vector.

pub async fn renew( &self, session_id: impl Into<String>, entries: Vec<QueueRenewEntry>, ) -> Result<Vec<QueueAckResult>, KrabkaError>

Renew queue message locks.

Errors

Returns an error when the session is invalid or the gateway request fails. Per-entry failures are returned in the result vector.

Trait Implementations

impl Clone for QueuesClient

fn clone(&self) -> QueuesClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueuesClient

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

Formats the value using the given formatter.