Struct CdcEvent 

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

A parsed CDC event from the stream.

Fields

stream_id: String

Stream entry ID (e.g., “1234567890123-0”)

op: CdcOp

Operation type

key: String

Object ID (key)

hash: Option<String>

Content hash for deduplication (only for PUT)

data: Option<Vec<u8>>

Decompressed data payload (only for PUT)

meta: Option<CdcMeta>

Parsed metadata (only for PUT)

Implementations

impl CdcEvent

pub fn is_put(&self) -> bool

Check if this is a PUT operation.

pub fn is_delete(&self) -> bool

Check if this is a DELETE operation.

pub fn trace_parent(&self) -> Option<&str>

Get the trace parent from metadata, if present.

Format: W3C Trace Context (e.g., “00-traceid-spanid-flags”)

pub fn trace_id(&self) -> Option<&str>

Extract trace ID from trace_parent (first 32 hex chars after version).

pub fn parent_span_id(&self) -> Option<&str>

Extract span ID from trace_parent (16 hex chars after trace ID).

Trait Implementations

impl Clone for CdcEvent

fn clone(&self) -> CdcEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CdcEvent

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

Formats the value using the given formatter.