Struct MongoCdcSourceConfig 

pub struct MongoCdcSourceConfig {
    pub connection_uri: String,
    pub scope: Scope,
    pub operation_types: Vec<String>,
    pub full_document: FullDocument,
    pub full_document_before_change: FullDocumentBeforeChange,
    pub start_from: StartFrom,
    pub aggregation_pipeline: Vec<Value>,
    pub idle_timeout: Duration,
    pub max_await_time_ms: u64,
    pub batch_size: usize,
    pub max_staged_records: Option<usize>,
}

Configuration for MongoCdcSource.

Fields

connection_uri: String

MongoDB connection URI. Must point at a replica set or sharded cluster.

scope: Scope

Which change stream to open.

operation_types: Vec<String>

Allowlist of operation types (insert/update/replace/delete/…). Empty = all. Prepended server-side as a $match on operationType.

full_document: FullDocument

Post-image inclusion mode.

full_document_before_change: FullDocumentBeforeChange

Pre-image inclusion mode (MongoDB 6.0+).

start_from: StartFrom

Start position on a fresh run (ignored once a bookmark exists, except an explicit resume_token/timestamp which overrides the bookmark).

aggregation_pipeline: Vec<Value>

Optional extra aggregation-pipeline stages, each a JSON object, appended after the operation-type $match.

idle_timeout: Duration

Terminator: flush the buffer and end the fetch cycle after this much quiet. Default 30s.

max_await_time_ms: u64

Server-side blocking getMore wait. Must be < idle_timeout. Default 1000.

batch_size: usize

Records per emitted StreamPage. 0 = drain until idle into one page.

max_staged_records: Option<usize>

Max change records buffered in memory before a page is emitted, after which the run aborts with a typed FaucetError::Source. None = unbounded. The OOM safety valve: with batch_size: 0 (or a library caller using fetch_all) the change-event buffer would otherwise grow without bound for the whole fetch cycle and risk an OOM-kill on a high-throughput stream. Mirrors the same field on the sibling postgres-cdc / mysql-cdc sources.

Implementations

impl MongoCdcSourceConfig

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

Validate fail-fast invariants. Called from MongoCdcSource::new.

Trait Implementations

impl Clone for MongoCdcSourceConfig

fn clone(&self) -> MongoCdcSourceConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MongoCdcSourceConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MongoCdcSourceConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for MongoCdcSourceConfig

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl Serialize for MongoCdcSourceConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.