Function make_cdc_event

nodedb-test-support/src/lib.rs:25–42

(seq: u64, partition: u32, collection: &str, op: &str)

/// Create a [`CdcEvent`] with sensible test defaults.
#[allow(dead_code)]
pub fn make_cdc_event(seq: u64, partition: u32, collection: &str, op: &str) -> CdcEvent {
    CdcEvent {
        sequence: seq,
        partition,
        collection: collection.into(),
        op: op.into(),
        row_id: format!("r-{seq}"),
        event_time: now_ms(),
        lsn: seq * 10,
        tenant_id: 1,
        new_value: Some(serde_json::json!({"id": seq})),
        old_value: None,
        schema_version: 0,
        field_diffs: None,
        system_time_ms: None,
        valid_time_ms: None,
    }
}