Struct StreamingGraphProcessor

pub struct StreamingGraphProcessor { /* private fields */ }

Streaming graph processor for handling incremental updates

Implementations

impl StreamingGraphProcessor

pub fn new(initial_graph: ArrowGraph) -> Self

Create a new streaming processor with an initial graph

pub fn empty() -> Result<Self>

Create an empty streaming processor

pub fn set_change_log_enabled(&mut self, enabled: bool)

Enable or disable change logging

pub fn graph(&self) -> &ArrowGraph

Get current graph state

pub fn update_count(&self) -> u64

Get current update count

pub fn apply_update(&mut self, update: StreamUpdate) -> Result<UpdateResult>

Apply a streaming update to the graph

pub fn apply_updates( &mut self, updates: Vec<StreamUpdate>, ) -> Result<Vec<UpdateResult>>

Apply multiple updates in sequence

pub fn get_change_log_since( &self, since_update: u64, ) -> Vec<(u64, StreamUpdate)>

Get the change log since a specific update count

pub fn get_statistics(&self) -> StreamingStatistics

Get statistics about the streaming processor

pub fn create_snapshot(&self) -> Result<GraphSnapshot>

Create a snapshot of the current graph state

pub fn restore_from_snapshot(&mut self, snapshot: GraphSnapshot)

Restore from a snapshot

pub fn compact_change_log(&mut self, keep_since: u64)

Compact the change log (remove entries older than specified update count)