Enum DbEvent 

pub enum DbEvent {
    EdgeFired {
        rule: String,
        src_key: String,
        dst_key: String,
        edge_type: String,
        weight: Option<f64>,
        commit_seq: u64,
    },
    EdgeRetracted {
        rule: String,
        src_key: String,
        dst_key: String,
        edge_type: String,
        commit_seq: u64,
    },
    NodeInserted {
        label: String,
        key: String,
        commit_seq: u64,
    },
    NodeDeleted {
        key: String,
        commit_seq: u64,
    },
    EdgeInserted {
        edge_type: String,
        src: String,
        dst: String,
        commit_seq: u64,
    },
    EdgeDeleted {
        edge_type: String,
        src: String,
        dst: String,
        commit_seq: u64,
    },
    PropSet {
        key: String,
        field: String,
        commit_seq: u64,
    },
    PropRemoved {
        key: String,
        field: String,
        commit_seq: u64,
    },
    Lagged {
        missed: u64,
    },
    QueryRowAdded {
        columns: Vec<String>,
        row: Vec<Option<Value>>,
    },
    QueryRowRemoved {
        columns: Vec<String>,
        row: Vec<Option<Value>>,
    },
}

A post-commit event delivered to subscribers.

Serialises as internally-tagged JSON ("type" discriminant, snake_case).

{"type":"edge_fired","rule":"skill_fit","src_key":"p1","dst_key":"proj-01",
 "edge_type":"FIT","weight":0.87,"commit_seq":42}
{"type":"lagged","missed":3}

Variants

EdgeFired

A rule derived a new edge.

Fields

rule: String

src_key: String

dst_key: String

edge_type: String

weight: Option<f64>

commit_seq: u64

EdgeRetracted

A rule retracted a previously derived edge.

Fields

rule: String

src_key: String

dst_key: String

edge_type: String

commit_seq: u64

NodeInserted

A node was inserted.

Fields

label: String

key: String

commit_seq: u64

NodeDeleted

A node was deleted.

Fields

key: String

commit_seq: u64

EdgeInserted

A user-inserted edge was added.

Fields

edge_type: String

src: String

dst: String

commit_seq: u64

EdgeDeleted

A user-inserted edge was deleted.

Fields

edge_type: String

src: String

dst: String

commit_seq: u64

PropSet

A property was set on a node.

Fields

key: String

field: String

commit_seq: u64

PropRemoved

A property was removed from a node.

Fields

key: String

field: String

commit_seq: u64

Lagged

One or more events were dropped due to a full queue.

The subscriber must re-read graph state to recover consistency for lossless consumers. missed is the count of dropped events.

Fields

missed: u64

QueryRowAdded

A row appeared in the result of a subscribe_query subscription.

Emitted after each commit when a full re-run of the subscribed Cypher query returns a row that was absent in the previous run.

Full re-run per commit; use LIMIT to bound execution cost.

Fields

columns: Vec<String>

row: Vec<Option<Value>>

QueryRowRemoved

A row disappeared from the result of a subscribe_query subscription.

Emitted after each commit when a row present in the previous run is absent from the current run.

Full re-run per commit; use LIMIT to bound execution cost.

Fields

columns: Vec<String>

row: Vec<Option<Value>>

Trait Implementations

impl Clone for DbEvent

fn clone(&self) -> DbEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DbEvent

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

Formats the value using the given formatter.

impl PartialEq for DbEvent

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for DbEvent

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 DbEvent