Struct CdcEntry 

pub struct CdcEntry {
    pub op: CdcOp,
    pub key: String,
    pub hash: Option<String>,
    pub data: Option<Vec<u8>>,
    pub meta: Option<String>,
}

A CDC entry ready to be written to the stream

Fields

op: CdcOp

Operation type

key: String

Object ID (key)

hash: Option<String>

Content hash for dedup (SHA256 of content) - only for PUT

data: Option<Vec<u8>>

Compressed data - only for PUT

meta: Option<String>

Metadata JSON - only for PUT

Implementations

impl CdcEntry

pub fn put( key: String, hash: String, content: &[u8], content_type: &str, version: u64, updated_at: i64, trace_parent: Option<String>, ) -> Self

Create a PUT entry

pub fn delete(key: String) -> Self

Create a DELETE entry

pub fn to_redis_fields(&self) -> Vec<(&'static str, CdcFieldValue)>

Convert to Redis XADD field-value pairs Returns Vec of (field, value) where value is either String or bytes

Trait Implementations

impl Clone for CdcEntry

fn clone(&self) -> CdcEntry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CdcEntry

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

Formats the value using the given formatter.