Module source 

MongoDB CDC source connector implementation.

Implements crate::connector::SourceConnector for streaming change events from MongoDB change streams into LaminarDB as Arrow RecordBatches.

Cancellation Safety

Connector lifecycle futures never directly poll the MongoDB driver. Driver I/O lives in an owned reader task; cancellation aborts that task so no connection or cursor outlives its connector.

Structs

MongoDbCdcSource

MongoDB CDC source connector.

Functions

mongodb_cdc_envelope_schema

Returns the Arrow schema for MongoDB CDC envelope records.