Struct SqliteEdgeRepository 

pub struct SqliteEdgeRepository { /* private fields */ }

SQLite-backed edge repository.

Implementations

impl SqliteEdgeRepository

pub fn new(conn: Arc<Mutex<Connection>>) -> Self

Create a new repository backed by the given connection.

Trait Implementations

impl Clone for SqliteEdgeRepository

fn clone(&self) -> SqliteEdgeRepository

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqliteEdgeRepository

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

Formats the value using the given formatter.

impl EdgeRepository for SqliteEdgeRepository

fn insert(&self, edge: &Edge) -> Result<Edge, StorageError>

Insert a new edge. Returns the edge with its assigned ID.

fn find_by_source(&self, source_id: NodeId) -> Result<Vec<Edge>, StorageError>

Find all edges originating from the given source node.

fn find_by_target(&self, target_id: NodeId) -> Result<Vec<Edge>, StorageError>

Find all edges targeting the given node.

fn find_by_type(&self, edge_type: EdgeType) -> Result<Vec<Edge>, StorageError>

Find all edges of the given type.

fn delete(&self, id: EdgeId) -> Result<(), StorageError>

Delete an edge by its ID.

fn delete_by_branch(&self, branch_id: &BranchId) -> Result<usize, StorageError>

Delete all edges for the given branch. Returns the number of rows deleted.