Struct PubSubPublisher 

pub struct PubSubPublisher { /* private fields */ }

Publishes messages to Pub/Sub topics, one client publisher per topic, created lazily and shared through the broker core (so shutdown can flush buffered batches).

A publish to a topic whose client publisher exists takes no lock held across an await and allocates nothing for the topic’s name.

The destination name is the topic id (short or full resource name). Message attributes carry headers directly, and the ordering key reaches the client as the message’s own field. Buildable before connect and usable until shutdown; afterwards every publish reports PubSubError::NotConnected instead of silently succeeding.

Trait Implementations

impl Clone for PubSubPublisher

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PubSubPublisher

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

Formats the value using the given formatter.

impl Publisher for PubSubPublisher

type Payload = Take

The client keeps the payload: a Pub/Sub message’s data is a Bytes, so the buffer the framework wrote becomes it.

type Error = PubSubError

The error type returned by publish.

type Options = PubSubPublishOptions

The broker’s per-message settings: a QoS, a priority, an ordering key, whatever this transport lets one message differ from the next in.

async fn publish( &self, msg: OutgoingMessage<'_, BytesMut>, options: Option<&Self::Options>, ) -> Result<(), Self::Error>

Publishes a message to the broker, with the per-message settings the call site adjusted.

fn base_headers(&self) -> Option<&HeaderMap>

The headers this publisher contributes to every message it sends, underneath whatever the message itself names.