Struct DeltaBatch 

pub struct DeltaBatch {
    pub source: SmolStr,
    pub timestamp: u64,
    pub deltas: Vec<GraphDelta>,
    pub vector_clock: Option<VectorClock>,
}

A batch of graph deltas from a single source, committed atomically.

All deltas in a batch are applied atomically (all or nothing). The timestamp is used for last-write-wins conflict resolution.

Fields

source: SmolStr

Source identifier: "file:src/main.rs", "doc:invoice_12345", etc.

timestamp: u64

Timestamp for last-write-wins ordering. Higher wins.

deltas: Vec<GraphDelta>

The mutations in this batch.

vector_clock: Option<VectorClock>

Optional causal ordering clock. None for most workloads.

Implementations

impl DeltaBatch

pub fn new(source: impl Into<SmolStr>, timestamp: u64) -> DeltaBatch

pub fn with_vector_clock( source: impl Into<SmolStr>, timestamp: u64, clock: VectorClock, ) -> DeltaBatch

pub fn push(&mut self, delta: GraphDelta)

pub fn extend(&mut self, deltas: impl IntoIterator<Item = GraphDelta>)

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn iter(&self) -> impl Iterator<Item = &GraphDelta>

pub fn node_upsert_count(&self) -> usize

pub fn edge_upsert_count(&self) -> usize

pub fn delete_count(&self) -> usize

pub fn referenced_labels(&self) -> Vec<SmolStr>

Collect all unique node table labels referenced in this batch.

pub fn referenced_rel_types(&self) -> Vec<SmolStr>

Collect all unique relationship types referenced in this batch.

Trait Implementations

impl Clone for DeltaBatch

fn clone(&self) -> DeltaBatch

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DeltaBatch

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

Formats the value using the given formatter.

impl PartialEq for DeltaBatch

fn eq(&self, other: &DeltaBatch) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for DeltaBatch