Module common_pubsub 

Available on crate features sink-pubsub or source-pubsub only.

Shared Google Cloud Pub/Sub types (credentials enum, connection block, client builder), re-exported when either Pub/Sub connector is enabled.

Structs

PubsubConnection

Connection settings shared by the Pub/Sub source and sink. Flattened into each connector config via #[serde(flatten)], so project_id / endpoint / emulator_host / credentials appear at the config top level.

PubsubMessage

A message that is published by publishers and consumed by subscribers. The message must contain either a non-empty data field or at least one attribute. Note that client libraries represent this object differently depending on the language. See the corresponding client library documentation for more information. See [quotas and limits] (https://cloud.google.com/pubsub/quotas) for more information about message limits.

Enums

PubsubCredentials

How to authenticate with Google Cloud Pub/Sub.

Functions

build_client

Build a Pub/Sub Client from a PubsubConnection.