Module pubsub 

Available on crate features source-pubsub and source-rest only.

Structs

PubsubBookmark

The persisted (informational) bookmark value.

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.

PubsubSource

Google Cloud Pub/Sub source. See the crate README for semantics.

PubsubSourceConfig

Configuration for PubsubSource.

Enums

PubsubCredentials

How to authenticate with Google Cloud Pub/Sub.

ValueFormat

How each message’s data payload is decoded into the emitted data field.

Constants

DEFAULT_ATTRIBUTES_KEY

The default JSON key the per-message attribute map is surfaced under.