Struct ChangeRecord 

pub struct ChangeRecord {
    pub term: u64,
    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>,
    pub refresh_records: Option<Vec<Vec<u8>>>,
}

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

Fields

term: u64

lsn: u64

timestamp: u64

operation: ChangeOperation

collection: String

entity_id: u64

entity_kind: String

entity_bytes: Option<Vec<u8>>

metadata: Option<Value>

refresh_records: Option<Vec<Vec<u8>>>

Issue #596 slice 9d — payload for ChangeOperation::Refresh. Each element is a serialized entity record (the same serialize_entity_record payload the store’s RefreshCollection WAL action uses), in the order the replica should bulk_insert after dropping the prior backing-collection contents.

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 for_refresh( lsn: u64, timestamp: u64, collection: impl Into<String>, records: Vec<Vec<u8>>, ) -> ChangeRecord

Build a refresh change record carrying the new contents for a REFRESH MATERIALIZED VIEW replay on the replica. Issue #596 slice 9d.

pub fn to_json_value(&self) -> Value

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

pub fn with_term(self, term: u64) -> ChangeRecord

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.