faucet-common-pubsub 1.0.0

Shared Google Cloud Pub/Sub credentials and client construction for the faucet-stream Pub/Sub source and sink connectors
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

#![cfg_attr(docsrs, feature(doc_cfg))]

//! # faucet-common-pubsub
//!
//! Shared configuration types for the faucet-stream Google Cloud Pub/Sub
//! source (`faucet-source-pubsub`) and sink (`faucet-sink-pubsub`)
//! connectors: the [`PubsubCredentials`] auth enum, the [`PubsubConnection`]
//! project / endpoint / emulator block, and the [`build_client`] helper that
//! assembles a `gcloud_pubsub::client::Client`. Both connector crates
//! re-export these so end-user imports do not change.
//!
//! Delivery is **at-least-once** — Pub/Sub itself provides no exactly-once
//! primitive that composes with faucet's watermark model, so neither
//! connector advertises exactly-once support.

mod client;
mod config;

pub use client::build_client;
pub use config::{PubsubConnection, PubsubCredentials};

// Re-export the SDK message type connector authors round-trip through, so
// downstream crates need only this crate on their import path.
pub use gcloud_googleapis::pubsub::v1::PubsubMessage;