Struct ChangeRecord 

pub struct ChangeRecord {
    pub lsn: u64,
    pub timestamp: u64,
    pub operation: ChangeOperation,
    pub collection: String,
    pub entity_id: u64,
    pub entity_kind: String,
    pub entity_bytes: Option<Vec<u8>>,
    pub metadata: Option<Value>,
}

Structured logical WAL record serialized into the replication buffer and archived segments.

Fields

lsn: u64

timestamp: u64

operation: ChangeOperation

collection: String

entity_id: u64

entity_kind: String

entity_bytes: Option<Vec<u8>>

metadata: Option<Value>

Implementations

impl ChangeRecord

pub fn from_entity( lsn: u64, timestamp: u64, operation: ChangeOperation, collection: impl Into<String>, entity_kind: impl Into<String>, entity: &UnifiedEntity, format_version: u32, metadata: Option<Value>, ) -> ChangeRecord

pub fn to_json_value(&self) -> Value

pub fn encode(&self) -> Vec<u8>

pub fn decode(bytes: &[u8]) -> Result<ChangeRecord, String>

Trait Implementations

impl Clone for ChangeRecord

fn clone(&self) -> ChangeRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChangeRecord

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

Formats the value using the given formatter.