Struct GraphSnapshot 

pub struct GraphSnapshot { /* private fields */ }

An owned snapshot of the graph at a point in time.

Unlike the current GraphSnapshot<'g>, this snapshot:

• Does not hold any locks
• Can be sent across threads (Send + Sync)
• Can outlive the source Graph
• Is immutable and will never change

Example

use interstellar::storage::cow::Graph;
use interstellar::storage::GraphStorage;
use std::collections::HashMap;
use std::thread;

let graph = Graph::new();
graph.add_vertex("person", HashMap::new());

let snap = graph.snapshot();

// Snapshot can be sent to another thread
let handle = thread::spawn(move || {
    snap.vertex_count()
});

assert_eq!(handle.join().unwrap(), 1);

Implementations

impl GraphSnapshot

pub fn version(&self) -> u64

Get the snapshot version.

pub fn interner(&self) -> &StringInterner

Get the string interner for this snapshot.

This returns a reference to the snapshot-local cloned interner.

pub fn arc_storage(&self) -> Arc<dyn GraphStorage + Send + Sync>

Get Arc-wrapped storage for streaming execution.

Returns a clone of self wrapped in Arc. Since GraphSnapshot implements GraphStorage, this enables streaming pipelines to own the storage without lifetime constraints.

pub fn arc_interner(&self) -> Arc<StringInterner>

Get Arc-wrapped interner for streaming execution.

Returns a clone of the internal Arc reference.

pub fn gremlin(&self) -> GraphTraversalSource<'_>

Create a Gremlin traversal source for this snapshot.

This provides the full Gremlin-style fluent API for querying the graph. Since GraphSnapshot is immutable, only read operations are available.

Example

use interstellar::storage::cow::Graph;
use interstellar::value::Value;
use std::collections::HashMap;

let graph = Graph::new();
graph.add_vertex("Person", HashMap::from([
    ("name".to_string(), Value::String("Alice".to_string())),
]));

let snapshot = graph.snapshot();
let g = snapshot.gremlin();

let count = g.v().has_label("Person").count();
assert_eq!(count, 1);

impl GraphSnapshot

pub fn arc_streamable(&self) -> Arc<dyn StreamableStorage>

Returns an Arc for use with StreamingExecutor.

This enables the traversal engine to hold an owned reference to the storage that can be used to create streaming iterators. The clone is cheap since GraphSnapshot is internally Arc-based.

Example

let snapshot = graph.snapshot();
let streamable = snapshot.arc_streamable();
let interner = snapshot.arc_interner();
let executor = StreamingExecutor::new_streaming(streamable, interner, ...);

Trait Implementations

impl Clone for GraphSnapshot

fn clone(&self) -> GraphSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl GraphStorage for GraphSnapshot

fn get_vertex(&self, id: VertexId) -> Option<Vertex>

Retrieves a vertex by its ID.

fn vertex_count(&self) -> u64

Returns the total number of vertices in the graph.

fn get_edge(&self, id: EdgeId) -> Option<Edge>

Retrieves an edge by its ID.

fn edge_count(&self) -> u64

Returns the total number of edges in the graph.

fn out_edges(&self, vertex: VertexId) -> Box<dyn Iterator<Item = Edge> + '_>

Returns an iterator over all outgoing edges from a vertex.

fn in_edges(&self, vertex: VertexId) -> Box<dyn Iterator<Item = Edge> + '_>

Returns an iterator over all incoming edges to a vertex.

fn vertices_with_label( &self, label: &str, ) -> Box<dyn Iterator<Item = Vertex> + '_>

Returns an iterator over all vertices with a given label.

fn edges_with_label(&self, label: &str) -> Box<dyn Iterator<Item = Edge> + '_>

Returns an iterator over all edges with a given label.

fn all_vertices(&self) -> Box<dyn Iterator<Item = Vertex> + '_>

Returns an iterator over all vertices in the graph.

fn all_edges(&self) -> Box<dyn Iterator<Item = Edge> + '_>

Returns an iterator over all edges in the graph.

fn interner(&self) -> &StringInterner

Returns a reference to the string interner for label resolution.

fn vertices_by_property( &self, label: Option<&str>, property: &str, value: &Value, ) -> Box<dyn Iterator<Item = Vertex> + '_>

Lookup vertices by property value, using indexes if available.

fn edges_by_property( &self, label: Option<&str>, property: &str, value: &Value, ) -> Box<dyn Iterator<Item = Edge> + '_>

Lookup edges by property value, using indexes if available.

fn vertices_by_property_range( &self, label: Option<&str>, property: &str, start: Bound<&Value>, end: Bound<&Value>, ) -> Box<dyn Iterator<Item = Vertex> + '_>

Lookup vertices by property range, using indexes if available.

fn supports_indexes(&self) -> bool

Returns whether this storage supports property indexes.

impl SnapshotLike for GraphSnapshot

fn storage(&self) -> &dyn GraphStorage

Get a reference to the underlying graph storage.

fn interner(&self) -> &StringInterner

Get a reference to the string interner for label resolution.

fn as_dyn(&self) -> &dyn SnapshotLike

Get a reference to self as a trait object.

fn arc_storage(&self) -> Arc<dyn GraphStorage + Send + Sync>

Get Arc-wrapped storage for streaming execution.

fn arc_interner(&self) -> Arc<StringInterner>

Get Arc-wrapped interner for streaming execution.

fn arc_streamable(&self) -> Arc<dyn StreamableStorage>

Get Arc-wrapped streamable storage for true O(1) streaming execution.

impl StreamableStorage for GraphSnapshot

fn stream_all_vertices(&self) -> Box<dyn Iterator<Item = VertexId> + Send>

Stream all vertex IDs without collecting.

fn stream_all_edges(&self) -> Box<dyn Iterator<Item = EdgeId> + Send>

Stream all edge IDs without collecting.

fn stream_vertices_with_label( &self, label: &str, ) -> Box<dyn Iterator<Item = VertexId> + Send>

Stream vertex IDs with a given label without collecting.

fn stream_edges_with_label( &self, label: &str, ) -> Box<dyn Iterator<Item = EdgeId> + Send>

Stream edge IDs with a given label without collecting.

fn stream_out_edges( &self, vertex: VertexId, ) -> Box<dyn Iterator<Item = EdgeId> + Send>

Stream outgoing edge IDs from a vertex without collecting.

fn stream_in_edges( &self, vertex: VertexId, ) -> Box<dyn Iterator<Item = EdgeId> + Send>

Stream incoming edge IDs to a vertex without collecting.

fn stream_out_neighbors( &self, vertex: VertexId, label_ids: &[u32], ) -> Box<dyn Iterator<Item = VertexId> + Send>

Stream outgoing neighbor vertex IDs without collecting.

fn stream_in_neighbors( &self, vertex: VertexId, label_ids: &[u32], ) -> Box<dyn Iterator<Item = VertexId> + Send>

Stream incoming neighbor vertex IDs without collecting.

fn stream_both_neighbors( &self, vertex: VertexId, label_ids: &[u32], ) -> Box<dyn Iterator<Item = VertexId> + Send>

Stream both incoming and outgoing neighbor vertex IDs.

impl Send for GraphSnapshot

impl Sync for GraphSnapshot