Struct MessagingClient 

pub struct MessagingClient { /* private fields */ }

Messaging module client.

Implementations

impl MessagingClient

pub async fn publish( &self, topic: impl Into<String>, value: impl Into<Bytes>, options: PublishOptions, ) -> Result<RecordResult, KrabkaError>

Publish one raw record.

Errors

Returns an error for invalid input, transport failures, or a gateway record error.

pub async fn publish_event( &self, topic: impl Into<String>, event: CloudEvent, ) -> Result<RecordResult, KrabkaError>

Publish a CloudEvent using the contract’s binary-mode header mapping.

Errors

Returns an error for invalid input, transport failures, or a gateway record error.

pub fn subscribe( &self, topics: &[String], group: impl Into<String>, filter: Option<&Filter>, ) -> Result<MessageStream, KrabkaError>

Subscribe to topics.

Errors

Returns an error for invalid topic or group input, an unreachable endpoint, or unavailable mock state.

Trait Implementations

impl Clone for MessagingClient

fn clone(&self) -> MessagingClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MessagingClient

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

Formats the value using the given formatter.