faucet_source_mongodb_cdc/lib.rs
1#![cfg_attr(docsrs, feature(doc_cfg))]
2//! MongoDB Change Streams (CDC) source for the faucet-stream ecosystem.
3//!
4//! Tails a collection / database / cluster change stream and emits per-document
5//! change events as a CDC envelope, resumable via the opaque `resumeToken`.
6
7mod config;
8mod envelope;
9mod state;
10mod stream;
11
12pub use config::{FullDocument, FullDocumentBeforeChange, MongoCdcSourceConfig, Scope, StartFrom};
13pub use state::{Bookmark, state_key};
14pub use stream::MongoCdcSource;