Struct google_cloud_pubsub::publisher::Publisher

pub struct Publisher { /* private fields */ }

Publisher is a scheduler which is designed for Pub/Sub’s Publish flow. Each item is added with a given key. Items added to the empty string key are handled in random order. Items added to any other key are handled sequentially.

Implementations

impl Publisher

pub async fn publish_immediately(
    &self,
    messages: Vec<PubsubMessage>,
    cancel: Option<CancellationToken>,
    retry: Option<RetrySetting>
) -> Result<Vec<String>, Status>

publish publishes msg to the topic synchronously

pub async fn publish(&self, message: PubsubMessage) -> Awaiter

publish publishes msg to the topic asynchronously. Messages are batched and sent according to the topic’s PublisherConfig. Publish never blocks.

publish returns a non-nil Awaiter which will be ready when the message has been sent (or has failed to be sent) to the server.

pub async fn publish_bulk(&self, messages: Vec<PubsubMessage>) -> Vec<Awaiter>

publish_bulk publishes msg to the topic asynchronously. Messages are batched and sent according to the topic’s PublisherConfig. Publish never blocks.

publish_bulk returns a non-nil Awaiter which will be ready when the message has been sent (or has failed to be sent) to the server.

pub async fn shutdown(&mut self)

Trait Implementations

impl Clone for Publisher

fn clone(&self) -> Publisher

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Publisher

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

Formats the value using the given formatter.