Module source 

MongoDB CDC source connector implementation.

Implements 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.