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::WriteConcernConfig;

pub use config::WriteConcernLevel;

pub use resume_token::FileResumeTokenStore;

pub use resume_token::InMemoryResumeTokenStore;

pub use resume_token::ResumeToken;

pub use resume_token::ResumeTokenStore;

pub use resume_token::ResumeTokenStoreConfig;

pub use sink::MongoDbSink;

pub use source::mongodb_cdc_envelope_schema;

pub use source::MongoDbCdcSource;

pub use timeseries::CollectionKind;

pub use timeseries::TimeSeriesConfig;

pub use timeseries::TimeSeriesGranularity;

pub use write_model::WriteMode;

pub use resume_token::MongoResumeTokenStore;

Modules

change_event

MongoDB change stream event types.

config

MongoDB connector configuration.

large_event

Large event fragment reassembly for MongoDB change streams.

metrics

MongoDB connector metrics.

resume_token

MongoDB change stream resume token persistence.

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.