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).

The destination name is the topic id (short or full resource name). A partition-key header becomes the message’s ordering key; per-key FIFO is the client’s ordered path. 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) -> PubSubPublisher

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 Error = PubSubError

The error type returned by publish.

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

Publishes a message to the broker.