Struct CommitNotification 

pub struct CommitNotification {
    pub version: u64,
    pub mutation_count: usize,
    pub labels_affected: Vec<String>,
    pub edge_types_affected: Vec<String>,
    pub rules_promoted: usize,
    pub timestamp: DateTime<Utc>,
    pub tx_id: String,
    pub session_id: String,
    pub causal_version: u64,
    pub mutations: Option<Arc<RecordBatch>>,
}

Describes a committed transaction’s effects.

Fields

version: u64

Database version after commit.

mutation_count: usize

Number of mutations in the committed transaction.

labels_affected: Vec<String>

Vertex labels that were affected by the commit.

edge_types_affected: Vec<String>

Edge types that were affected by the commit.

rules_promoted: usize

Number of Locy rules promoted from the transaction.

timestamp: DateTime<Utc>

Timestamp of the commit.

tx_id: String

Transaction ID.

session_id: String

Session ID that committed the transaction.

causal_version: u64

Database version when the transaction started (for causal ordering).

mutations: Option<Arc<RecordBatch>>

Per-row mutation events for this commit, in the canonical event_row_schema shape (event_kind, vid_or_eid, label, property, old_value, new_value, properties_new, properties_old).

Some only when at least one CdcOutputProvider is registered at commit time — the empty-registry hot path broadcasts None so the trigger / watch surface pays no extraction cost when CDC is unused. The CdcRuntime consumes this field directly; user-facing session.watch() consumers ignore it.

Trait Implementations

impl Clone for CommitNotification

fn clone(&self) -> CommitNotification

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CommitNotification

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

Formats the value using the given formatter.