Enum MutationEvent 

pub enum MutationEvent {
    NodeInserted {
        label: String,
        key: String,
    },
    PropSet {
        key: String,
        field: String,
    },
    PropRemoved {
        key: String,
        field: String,
    },
    EdgeInserted {
        edge_type: String,
        src: String,
        dst: String,
    },
    EdgeDeleted {
        edge_type: String,
        src: String,
        dst: String,
    },
    NodeDeleted {
        key: String,
    },
    RuleCreated {
        name: String,
    },
    RuleDeleted {
        name: String,
    },
    RuleRebuilt {
        name: String,
    },
    BatchApplied {
        ops: usize,
    },
    Ingested {
        label: String,
        inserted: usize,
    },
}

A post-commit mutation notification.

Emitted from log_then_apply after the WAL append, fsync, and in-memory apply all succeed. Never emitted for rejected operations (validation errors, GraphError::RuleOwned, duplicate keys, no-op deletes/removes). Event payloads carry user keys and rule names, never internal ids.

Replay: GraphDb::open / GraphDb::open_with replay the WAL via apply only. Emission lives exclusively in log_then_apply, so recovery is silent even if a sink were installed (it cannot be: the sink is in-memory and set after open).

Ordering: a Batch WAL frame emits one event per inner record, then MutationEvent::BatchApplied. An ingest commit emits those same inner events, then MutationEvent::Ingested (not BatchApplied). An empty or all-noop batch writes no WAL and emits nothing (including no summary).

Derived edges: rule-created or retracted edges are not individually evented — they are recoverable from the triggering mutation plus the live rule set. Only the triggering record is emitted.

Wire form: externally tagged snake_case JSON ({"node_inserted":{"label":"A","key":"k"}}).

Variants

NodeInserted

Fields

label: String

key: String

PropSet

Fields

key: String

field: String

PropRemoved

Fields

key: String

field: String

EdgeInserted

Fields

edge_type: String

src: String

dst: String

EdgeDeleted

Fields

edge_type: String

src: String

dst: String

NodeDeleted

Fields

key: String

RuleCreated

Fields

name: String

RuleDeleted

Fields

name: String

RuleRebuilt

Fields

name: String

BatchApplied

Fields

ops: usize

Ingested

Fields

label: String

inserted: usize

Trait Implementations

impl Clone for MutationEvent

fn clone(&self) -> MutationEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MutationEvent

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

Formats the value using the given formatter.

impl Eq for MutationEvent

impl PartialEq for MutationEvent

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for MutationEvent

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for MutationEvent