Struct DataStore 

pub struct DataStore { /* private fields */ }

Implementations

impl DataStore

pub fn create(path: &Path) -> IsamResult<Self>

Create a new, empty .idb file, truncating any existing one.

pub fn open(path: &Path) -> IsamResult<Self>

Open an existing .idb file for reading and appending.

pub fn append<K, V>(&mut self, key: &K, value: &V) -> IsamResult<RecordRef>

where K: Serialize, V: Serialize,

Append a live record to the file.

Returns a RecordRef containing the byte offset and length so the B-tree index can locate this record later.

pub fn append_tombstone<K>(&mut self, key: &K) -> IsamResult<()>

where K: Serialize,

Append a tombstone record for key.

The value portion is zero bytes; the B-tree entry will be removed separately, so tombstones in the data file are only needed for compaction safety.

pub fn read_value<V>(&mut self, rec: RecordRef) -> IsamResult<V>

where V: DeserializeOwned,

Read and deserialize the value portion of the record at rec.

&mut self because Seek requires mutability on the file handle.

pub fn read_record_raw( &mut self, offset: u64, ) -> IsamResult<(u8, Vec<u8>, Vec<u8>)>

Read the raw bytes of a record (for use during compaction).

Returns (status, key_bytes, val_bytes).

pub fn write_raw_record( &mut self, status: u8, key_bytes: &[u8], val_bytes: &[u8], ) -> IsamResult<RecordRef>

Write a raw pre-encoded record directly (used during compaction to copy records without re-serializing).

pub fn flush(&mut self) -> IsamResult<()>

Flush OS buffers to disk.

pub fn fsync(&mut self) -> IsamResult<()>

Flush OS buffers and call fsync to ensure durability.