Struct MongoDbSourceConfig 

pub struct MongoDbSourceConfig {
    pub connection_uri: String,
    pub database: String,
    pub collection: String,
    pub full_document_mode: FullDocumentMode,
    pub pipeline: Vec<Value>,
    pub split_large_events: bool,
    pub resume_token_store: ResumeTokenStoreConfig,
    pub max_await_time_ms: Option<u64>,
    pub batch_size: Option<u32>,
    pub start_at_operation_time: Option<(u32, u32)>,
    pub max_buffered_events: usize,
    pub max_poll_records: usize,
}

Configuration for the MongoDB CDC source connector.

Fields

connection_uri: String

MongoDB connection URI (e.g., mongodb://host:27017).

database: String

Database name.

collection: String

Collection name, or "*" to watch all collections in the database.

full_document_mode: FullDocumentMode

Full document retrieval mode for update events.

pipeline: Vec<Value>

Additional aggregation pipeline stages injected before the change stream opens. Callers can inject $match, $project, etc.

Constraint: Pipeline stages must not modify the _id field. This is validated at construction.

split_large_events: bool

Whether to enable $changeStreamSplitLargeEvent (MongoDB ≥ 6.0.9).

resume_token_store: ResumeTokenStoreConfig

Resume token persistence configuration.

max_await_time_ms: Option<u64>

getMore await timeout in milliseconds.

batch_size: Option<u32>

Cursor batch size hint.

start_at_operation_time: Option<(u32, u32)>

For fresh starts with no persisted token, start at this operation time. Encoded as { t: <seconds>, i: <increment> }.

max_buffered_events: usize

Maximum events to buffer before applying backpressure.

max_poll_records: usize

Maximum records to return per poll_batch call.

Implementations

impl MongoDbSourceConfig

pub fn new(connection_uri: &str, database: &str, collection: &str) -> Self

Creates a new source config with required fields.

pub fn is_database_watch(&self) -> bool

Returns true if the source is configured to watch all collections.

pub fn validate(&self) -> Result<(), ConnectorError>

Validates the configuration.

Errors

Returns ConnectorError::ConfigurationError for invalid settings.

pub fn from_config(config: &ConnectorConfig) -> Result<Self, ConnectorError>

Parses configuration from a generic ConnectorConfig.

Errors

Returns ConnectorError if required keys are missing or invalid.

Trait Implementations

impl Clone for MongoDbSourceConfig

fn clone(&self) -> MongoDbSourceConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MongoDbSourceConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for MongoDbSourceConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for MongoDbSourceConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for MongoDbSourceConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.