Struct GraphCollection 

pub struct GraphCollection { /* private fields */ }

A graph collection storing typed relationships between nodes.

Node embeddings are optional: if dimension is None, no vector index is created.

Examples

use velesdb_core::{GraphCollection, GraphSchema, GraphEdge, DistanceMetric};

let coll = GraphCollection::create(
    "./data/kg".into(),
    "knowledge",
    None,                    // no embeddings
    DistanceMetric::Cosine,  // unused when no embeddings
    GraphSchema::schemaless(),
)?;

let edge = GraphEdge::new(1, 100, 200, "KNOWS")?;
coll.add_edge(edge)?;

Implementations

impl GraphCollection

pub fn create( path: PathBuf, name: &str, dimension: Option<usize>, metric: DistanceMetric, schema: GraphSchema, ) -> Result<Self>

Creates a new GraphCollection.

Errors

Returns an error if the directory cannot be created or storage fails.

pub fn open(path: PathBuf) -> Result<Self>

Opens an existing GraphCollection from disk.

Errors

Returns an error if config or storage cannot be opened.

pub fn flush(&self) -> Result<()>

Flushes all state to disk.

Errors

Returns an error if any flush operation fails.

pub fn name(&self) -> String

Returns the collection name.

pub fn schema(&self) -> GraphSchema

Returns the graph schema stored in config.

Returns GraphSchema::schemaless() for collections that have no schema set.

pub fn has_embeddings(&self) -> bool

Returns true if this collection stores node embeddings.

pub fn add_edge(&self, edge: GraphEdge) -> Result<()>

Adds an edge between two nodes.

Errors

Returns Error::EdgeExists if an edge with the same ID already exists.

pub fn get_edges(&self, label: Option<&str>) -> Vec<GraphEdge>

Returns edges, optionally filtered by label.

pub fn get_outgoing(&self, node_id: u64) -> Vec<GraphEdge>

Returns all outgoing edges from a node.

pub fn get_incoming(&self, node_id: u64) -> Vec<GraphEdge>

Returns all incoming edges to a node.

pub fn node_degree(&self, node_id: u64) -> (usize, usize)

Returns (in_degree, out_degree) for a node.

pub fn traverse_bfs( &self, source_id: u64, config: &TraversalConfig, ) -> Vec<TraversalResult>

Performs BFS traversal from a source node.

pub fn traverse_dfs( &self, source_id: u64, config: &TraversalConfig, ) -> Vec<TraversalResult>

Performs DFS traversal from a source node.

pub fn store_node_payload(&self, node_id: u64, payload: &Value) -> Result<()>

Stores node payload (properties).

Errors

Returns an error if storage fails.

pub fn get_node_payload(&self, node_id: u64) -> Result<Option<Value>>

Retrieves node payload.

Errors

Returns an error if retrieval fails.

pub fn search_by_embedding( &self, query: &[f32], k: usize, ) -> Result<Vec<SearchResult>>

Searches for similar nodes by embedding (only available if has_embeddings()).

Errors

Returns Error::VectorNotAllowed if this collection has no embeddings, or Error::DimensionMismatch if the query dimension is wrong.

pub fn execute_query( &self, query: &Query, params: &HashMap<String, Value>, ) -> Result<Vec<SearchResult>>

Executes a VelesQL query.

Errors

Returns an error if the query is invalid or execution fails.

Trait Implementations

impl Clone for GraphCollection

fn clone(&self) -> GraphCollection

Returns a duplicate of the value.

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

Performs copy-assignment from source.