Struct PersistenceManager 

pub struct PersistenceManager { /* private fields */ }

Integrated persistence manager combining WAL, storage, and tenancy

Implementations

impl PersistenceManager

pub fn new(base_path: impl AsRef<Path>) -> Result<Self, PersistenceError>

Create a new persistence manager

pub fn tenants(&self) -> &TenantManager

Get tenant manager

pub fn start_indexer( &self, store: &GraphStore, receiver: UnboundedReceiver<IndexEvent>, )

Start the background indexer for a store

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

Persist a node creation

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

Persist an edge creation

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

Persist a node deletion

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

Persist an edge deletion

pub fn persist_update_node_properties( &self, tenant: &str, node_id: u64, properties: &PropertyMap, ) -> Result<(), PersistenceError>

Update node properties

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

List all tenants that have persisted data in RocksDB

pub fn recover( &self, tenant: &str, ) -> Result<(Vec<Node>, Vec<Edge>), PersistenceError>

Recover from storage and WAL

pub fn checkpoint(&self) -> Result<(), PersistenceError>

Create a checkpoint

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

Flush all pending writes

pub fn storage(&self) -> &PersistentStorage

Get storage reference

pub fn checkpoint_vectors( &self, vector_index: &VectorIndexManager, ) -> Result<(), PersistenceError>

Save vector indices to disk

pub fn recover_vectors( &self, vector_index: &VectorIndexManager, ) -> Result<(), PersistenceError>

Load vector indices from disk