Struct PersistentStorage 

pub struct PersistentStorage { /* private fields */ }

RocksDB-based persistent storage

Implementations

impl PersistentStorage

pub fn open(path: impl AsRef<Path>) -> Result<PersistentStorage, StorageError>

Open or create a new persistent storage

pub fn put_node(&self, tenant: &str, node: &Node) -> Result<(), StorageError>

Store a node

pub fn get_node( &self, tenant: &str, node_id: u64, ) -> Result<Option<Node>, StorageError>

Get a node

pub fn put_edge(&self, tenant: &str, edge: &Edge) -> Result<(), StorageError>

Store an edge

pub fn get_edge( &self, tenant: &str, edge_id: u64, ) -> Result<Option<Edge>, StorageError>

Get an edge

pub fn delete_node( &self, tenant: &str, node_id: u64, ) -> Result<(), StorageError>

Delete a node

pub fn delete_edge( &self, tenant: &str, edge_id: u64, ) -> Result<(), StorageError>

Delete an edge

pub fn create_snapshot( &self, ) -> SnapshotWithThreadMode<'_, DBCommon<SingleThreaded, DBWithThreadModeInner>>

Create a snapshot

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

Flush all data to disk

pub fn scan_nodes(&self, tenant: &str) -> Result<Vec<Node>, StorageError>

Get all nodes for a tenant (for recovery)

pub fn scan_edges(&self, tenant: &str) -> Result<Vec<Edge>, StorageError>

Get all edges for a tenant (for recovery)

pub fn list_persisted_tenants(&self) -> Result<Vec<String>, StorageError>

List all tenants that have persisted data