Enum StreamUpdate

pub enum StreamUpdate {
    AddNode {
        node_id: String,
    },
    RemoveNode {
        node_id: String,
    },
    AddEdge {
        source: String,
        target: String,
        weight: Option<f64>,
    },
    RemoveEdge {
        source: String,
        target: String,
    },
    UpdateEdgeWeight {
        source: String,
        target: String,
        weight: f64,
    },
    Batch {
        operations: Vec<StreamUpdate>,
    },
}

Streaming graph update operations for incremental processing

Variants

AddNode

Add a new node

Fields

node_id: String

RemoveNode

Remove an existing node

Fields

node_id: String

AddEdge

Add a new edge

Fields

source: String

target: String

weight: Option<f64>

RemoveEdge

Remove an existing edge

Fields

source: String

target: String

UpdateEdgeWeight

Update edge weight

Fields

source: String

target: String

weight: f64

Batch

Batch of multiple operations

Fields

operations: Vec<StreamUpdate>

Trait Implementations

impl Clone for StreamUpdate

fn clone(&self) -> StreamUpdate

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamUpdate

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

Formats the value using the given formatter.