Module mongodb 

MongoDB CDC source and sink connectors. MongoDB CDC source and sink connectors.

Re-exports

pub use config::FullDocumentMode;

pub use config::MongoDbSinkConfig;

pub use config::MongoDbSourceConfig;

pub use config::SnapshotMode;

pub use config::SourceOutputMode;

pub use sink::MongoDbSink;

pub use source::mongodb_history_schema;

pub use source::MongoDbCdcSource;

pub use source::MONGODB_HISTORY_VERSION;

pub use source::SNAPSHOT_OPERATION;

pub use timeseries::CollectionKind;

pub use timeseries::TimeSeriesConfig;

pub use timeseries::TimeSeriesGranularity;

pub use write_model::WriteMode;

Modules

change_event

MongoDB change-event classification and canonical Extended JSON rendering.

config

MongoDB connector configuration.

lookup

MongoDB on-demand lookup source for cache-miss fallback.

metrics

MongoDB connector metrics.

sink

MongoDB sink connector implementation.

source

MongoDB CDC source connector implementation.

timeseries

MongoDB time series collection configuration and validation.

write_model

Write mode configuration for the MongoDB sink connector.

Functions

register_mongodb_cdc_source

Registers the MongoDB CDC source connector with the given registry.

register_mongodb_sink

Registers the MongoDB sink connector with the given registry.