Struct MongoDbChangeEvent 

pub struct MongoDbChangeEvent {
    pub operation_type: OperationType,
    pub namespace: Namespace,
    pub document_key: String,
    pub full_document: Option<String>,
    pub update_description: Option<UpdateDescription>,
    pub cluster_time_secs: u32,
    pub cluster_time_inc: u32,
    pub resume_token: String,
    pub wall_time_ms: i64,
}

A change event from a MongoDB change stream.

This struct captures all fields relevant for CDC processing. The resume_token is the opaque _id field from the change event document, used for resuming the stream.

Fields

operation_type: OperationType

The operation type.

namespace: Namespace

The namespace (database + collection).

document_key: String

The document key (_id and any shard key fields). Serialized as a JSON string for Arrow compatibility.

full_document: Option<String>

The full document (present for insert, replace, and optionally for update events depending on FullDocumentMode).

update_description: Option<UpdateDescription>

Update delta (only for update operations).

cluster_time_secs: u32

Server timestamp of the operation (cluster time).

cluster_time_inc: u32

Cluster time increment.

resume_token: String

The opaque resume token for this event, serialized as JSON.

wall_time_ms: i64

Wall clock timestamp in milliseconds since Unix epoch.

Trait Implementations

impl Clone for MongoDbChangeEvent

fn clone(&self) -> MongoDbChangeEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MongoDbChangeEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MongoDbChangeEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for MongoDbChangeEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.