Enum StreamEvent 

pub enum StreamEvent {
    Insert {
        key: String,
        value: Vec<u8>,
    },
    Update {
        key: String,
        value: Vec<u8>,
    },
    Delete {
        key: String,
    },
}

스트림 이벤트 — INSERT / UPDATE / DELETE를 통합 표현

CDC (Change Data Capture) 및 이벤트 소싱 패턴에서 스트림으로 전달되는 모든 DML 연산을 지원합니다.

주의

Update는 DBX의 key 기반 upsert 시맨틱을 활용하므로 내부적으로 db.insert()를 재사용합니다.

Variants

Insert

새 레코드 삽입

Fields

key: String

value: Vec<u8>

Update

기존 레코드 갱신 (키 기반 upsert)

Fields

key: String

value: Vec<u8>

Delete

레코드 삭제 (키 기반)

Fields

key: String

Trait Implementations

impl Clone for StreamEvent

fn clone(&self) -> StreamEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamEvent

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

Formats the value using the given formatter.