Struct VersionedGraphStore 

pub struct VersionedGraphStore<'a, G: GraphStore> { /* private fields */ }

Implementations

impl<'a, G: GraphStore + Clone> VersionedGraphStore<'a, G>

pub fn new(base: &'a mut G, graph: impl Into<String>) -> Self

pub fn version(&self) -> u64

pub fn base(&self) -> &G

pub fn base_mut(&mut self) -> &mut G

pub fn apply(&mut self, delta: GraphDelta) -> GraphStoreResult<u64>

Apply a delta to the base store, accumulating an inverse delta for rollback. Returns the new version number.

pub fn rollback(&mut self, to_version: u64) -> GraphStoreResult<()>

Rewind to the given version by replaying inverse deltas. Errors when the target version is in the future or below zero.

pub fn on_invalidate<F>(&mut self, callback: F)

where F: Fn(&BTreeSet<String>) + Send + Sync + 'static,

Register a callback fired with the set of affected edge labels every time apply lands a delta that touches at least one edge.