Struct DataStorage 

pub struct DataStorage { /* private fields */ }

Implementations

impl DataStorage

pub fn new<P: AsRef<Path>>( database_dir: P, storage_id: StorageId, formatter: Arc<BitcaskyFormatter>, options: Arc<BitcaskyOptions>, ) -> Result<Self>

pub fn open<P: AsRef<Path>>( database_dir: P, storage_id: StorageId, options: Arc<BitcaskyOptions>, ) -> Result<Self>

pub fn storage_id(&self) -> StorageId

pub fn is_dirty(&mut self) -> bool

pub fn iter(&self) -> Result<StorageIter>

pub fn get_telemetry_data(&self) -> DataStorageTelemetry

Trait Implementations

impl DataStorageReader for DataStorage

fn read_value( &mut self, row_offset: usize, ) -> Result<Option<TimedValue<Vec<u8>>>>

Read value from this storage at row_offset

fn read_next_row(&mut self) -> Result<Option<RowToRead>>

Read next value from this storage

fn seek_to_end(&mut self) -> Result<()>

fn offset(&self) -> usize

impl DataStorageWriter for DataStorage

fn write_row<K: AsRef<[u8]>, V: Deref<Target = [u8]>>( &mut self, row: &RowToWrite<K, V>, ) -> Result<RowLocation>

fn rewind(&mut self) -> Result<()>

fn flush(&mut self) -> Result<()>

impl Debug for DataStorage

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

Formats the value using the given formatter.