Struct TablePersistence 

pub struct TablePersistence { /* private fields */ }

Registry of durable column mirrors keyed by table id.

Implementations

impl TablePersistence

pub fn new() -> Self

pub fn remove( &self, table_id: u64, db_path: &Path, bm: &Arc<Mutex<BufferManager>>, )

Delete the mirror files for a dropped table.

pub fn sync_node_table( &self, table: &mut NodeTable, db_path: &Path, bm: &Arc<Mutex<BufferManager>>, page_size: usize, ) -> Result<(), StorageError>

Persist table’s rows into its durable column mirror.

pub fn load_node_table( &self, table: &mut NodeTable, db_path: &Path, bm: &Arc<Mutex<BufferManager>>, page_size: usize, ) -> Result<bool, StorageError>

Load a node table from its durable column mirror.

Returns Ok(true) when data was loaded, Ok(false) when no mirror exists yet (fresh table).

pub fn sync_rel_table( &self, table: &mut RelTable, db_path: &Path, bm: &Arc<Mutex<BufferManager>>, page_size: usize, ) -> Result<(), StorageError>

Persist table’s edges + properties into its durable column mirror.

Mirror layout: [src: UInt64][dst: UInt64][prop_0..prop_n]. Deleted edges are stored as (u64::MAX, u64::MAX) tombstones so edge indices stay stable across restarts.

pub fn load_rel_table( &self, table: &mut RelTable, db_path: &Path, bm: &Arc<Mutex<BufferManager>>, page_size: usize, ) -> Result<bool, StorageError>

Load a rel table from its durable column mirror.

pub fn persist_all( &self, catalog: &Arc<TableCatalog>, db_path: &Path, bm: &Arc<Mutex<BufferManager>>, page_size: usize, ) -> Result<(), StorageError>

Sync all node + rel tables into their durable mirrors.

pub fn load_all( &self, catalog: &Arc<TableCatalog>, db_path: &Path, bm: &Arc<Mutex<BufferManager>>, page_size: usize, ) -> Result<usize, StorageError>

Load all persisted tables from their durable mirrors.

Returns the number of tables that had persisted data.

Trait Implementations

impl Debug for TablePersistence

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

Formats the value using the given formatter.

impl Default for TablePersistence

fn default() -> TablePersistence

Returns the “default value” for a type.