Crate faucet_source_mongodb_cdc 

MongoDB Change Streams (CDC) source for the faucet-stream ecosystem.

Tails a collection / database / cluster change stream and emits per-document change events as a CDC envelope, resumable via the opaque resumeToken.

Structs

Bookmark

Durable bookmark wrapping a resume token.

MongoCdcSource

A configured MongoDB CDC source.

MongoCdcSourceConfig

Configuration for MongoCdcSource.

Enums

FullDocument

Post-image inclusion mode (maps to the driver FullDocumentType).

FullDocumentBeforeChange

Pre-image inclusion mode (maps to the driver FullDocumentBeforeChangeType).

Scope

Which change stream to open.

StartFrom

Where to start the change stream on a fresh run (no persisted bookmark).

Functions

state_key

State key for a given watch scope.