Enum GraphOp 

pub enum GraphOp {
    DefineOntology {
        ontology: Ontology,
    },
    AddNode {
        node_id: String,
        node_type: String,
        subtype: Option<String>,
        label: String,
        properties: BTreeMap<String, Value>,
    },
    AddEdge {
        edge_id: String,
        edge_type: String,
        source_id: String,
        target_id: String,
        properties: BTreeMap<String, Value>,
    },
    UpdateProperty {
        entity_id: String,
        key: String,
        value: Value,
    },
    RemoveNode {
        node_id: String,
    },
    RemoveEdge {
        edge_id: String,
    },
    ExtendOntology {
        extension: OntologyExtension,
    },
    Checkpoint {
        ops: Vec<GraphOp>,
        op_clocks: Vec<(u64, u32)>,
        compacted_at_physical_ms: u64,
        compacted_at_logical: u32,
    },
}

Graph operations — the payload of each Merkle-DAG entry.

DefineOntology must be the first (genesis) entry. All subsequent operations are validated against the ontology it defines.

Variants

DefineOntology

Genesis entry — defines the initial ontology (extendable via R-03 ExtendOntology). Must be the first entry in the DAG (next = []).

Fields

ontology: Ontology

AddNode

Fields

node_id: String

node_type: String

subtype: Option<String>

label: String

properties: BTreeMap<String, Value>

AddEdge

Fields

edge_id: String

edge_type: String

source_id: String

target_id: String

properties: BTreeMap<String, Value>

UpdateProperty

Fields

entity_id: String

key: String

value: Value

RemoveNode

Fields

node_id: String

RemoveEdge

Fields

edge_id: String

ExtendOntology

R-03: Extend the ontology with new types/properties (monotonic only).

Fields

extension: OntologyExtension

Checkpoint

R-08: Checkpoint entry — summarizes all prior state. Contains synthetic ops that reconstruct the full graph when replayed. After compaction, this becomes the new genesis (next=[]).

Fields

ops: Vec<GraphOp>

Synthetic ops that reconstruct the graph state

op_clocks: Vec<(u64, u32)>

Per-op clocks: (physical_ms, logical) for each op. Bug 6 fix: preserves per-entity clock metadata for correct LWW after compaction.

compacted_at_physical_ms: u64

Physical timestamp when compaction was performed

compacted_at_logical: u32

Logical timestamp when compaction was performed

Trait Implementations

impl Clone for GraphOp

fn clone(&self) -> GraphOp

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GraphOp

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for GraphOp

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for GraphOp

fn eq(&self, other: &GraphOp) -> 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 Serialize for GraphOp

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 GraphOp