Struct MutationWriteSet 

pub struct MutationWriteSet {
    pub nodes: BTreeSet<NodeId>,
    pub rels: BTreeSet<RelationshipId>,
    pub cleared: bool,
}

Set of record ids touched by a buffered MutationEvent stream.

Built incrementally as events buffer (or in one pass at commit time) by MutationWriteSet::extend_from_events. Used by the OCC auto-commit path to (a) sort lock-acquire on commit, (b) validate per-record Arc identity against the snapshot.

Fields

nodes: BTreeSet<NodeId>

Nodes whose record was created, modified, or deleted.

rels: BTreeSet<RelationshipId>

Relationships whose record was created, modified, or deleted.

cleared: bool

true if the stream contained a MutationEvent::Clear. A clear invalidates any per-record check — the writer must fall back to a full-graph commit (or fail under OCC).

Implementations

impl MutationWriteSet

pub fn new() -> Self

pub fn extend_from_events<'a>( &mut self, events: impl IntoIterator<Item = &'a MutationEvent>, )

Walk a MutationEvent stream and accumulate every touched record id. Variants that touch two records (e.g. CreateRelationship mentions both src and dst plus the new relationship) record both nodes — the writer’s view of those nodes’ adjacency changed too.

pub fn is_empty(&self) -> bool

Trait Implementations

impl Clone for MutationWriteSet

fn clone(&self) -> MutationWriteSet

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MutationWriteSet

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

Formats the value using the given formatter.

impl Default for MutationWriteSet

fn default() -> MutationWriteSet

Returns the “default value” for a type.