Struct Storage 

pub struct Storage { /* private fields */ }

Implementations

impl Storage

pub fn create(path: &Path) -> Result<Self, MqdbError>

Create a new empty database file. Writes file header + empty catalog.

pub fn open(path: &Path) -> Result<Self, MqdbError>

Open an existing database file. Validates magic + version.

Accepts both the current file format and older, still-recognised versions (see page::LEGACY_VERSIONS) — check Storage::file_version to tell which one was actually read.

pub fn file_version(&self) -> u32

The file-format version this store was read from. page::FILE_VERSION for stores created by this build; an older value for a legacy file that was opened for read/migration.

pub fn num_pages(&self) -> u32

Total pages in the file, including the header and catalog pages.

pub fn write_document(&mut self, doc: &Document) -> Result<u32, MqdbError>

Write one document’s blocks to the page file. Returns the first_block_page.

pub fn read_blocks( &mut self, first_page: u32, num_blocks: u32, ) -> Result<Vec<Block>, MqdbError>

Read all blocks for a document given its first_block_page and num_blocks.

pub fn flush_catalog( &mut self, entries: &[CatalogEntry], custom_tables: &[CustomTableEntry], content_hashes: &[(u32, u64)], views: &[ViewEntry], ) -> Result<(), MqdbError>

Save catalog (call after all write_document calls).

pub fn load_catalog(&mut self) -> Result<CatalogData, MqdbError>

Read the catalog.

pub fn write_index(&mut self, bytes: &[u8]) -> Result<u32, MqdbError>

Write raw index bytes as a chained page sequence. Returns the first page id.

pub fn read_index_bytes( &mut self, first_page: u32, ) -> Result<Vec<u8>, MqdbError>

Read all bytes from an index page chain starting at first_page.

pub fn write_table_rows( &mut self, rows: &[Vec<String>], ) -> Result<(u32, u32), MqdbError>

Write a fresh chain of table-row pages, starting a brand-new table. Returns (first_page, last_page), or (0, 0) if rows is empty (nothing written — 0 is never a valid page id).

pub fn append_table_rows( &mut self, tail_page: u32, rows: &[Vec<String>], ) -> Result<u32, MqdbError>

Append rows after an existing table-row chain by writing new pages and relinking the current tail (tail_page) to point at them. Returns the new tail page id (unchanged if rows is empty).

pub fn read_table_rows( &mut self, first_page: u32, num_rows: u32, num_cols: usize, ) -> Result<Vec<Vec<String>>, MqdbError>

Read all rows for a table given its chain head, row count, and column count.