Enum RocksDB

pub enum RocksDB {
    DBWithThreadMode(DBWithThreadModeWrapper),
    OptimisticTransactionDB(OptimisticTransactionDBWrapper),
}

Thin wrapper to unify interface across different db types

Variants

DBWithThreadMode(DBWithThreadModeWrapper)

OptimisticTransactionDB(OptimisticTransactionDBWrapper)

Implementations

impl RocksDB

pub fn get<K: AsRef<[u8]>>(&self, key: K) -> Result<Option<Vec<u8>>, Error>

pub fn multi_get_cf<'a, 'b: 'a, K, I, W>( &'a self, keys: I, readopts: &ReadOptions, ) -> Vec<Result<Option<Vec<u8>>, Error>>

where K: AsRef<[u8]>, I: IntoIterator<Item = (&'b W, K)>, W: 'b + AsColumnFamilyRef,

pub fn batched_multi_get_cf_opt<I, K>( &self, cf: &impl AsColumnFamilyRef, keys: I, sorted_input: bool, readopts: &ReadOptions, ) -> Vec<Result<Option<DBPinnableSlice<'_>>, Error>>

where I: IntoIterator<Item = K>, K: AsRef<[u8]>,

pub fn property_int_value_cf( &self, cf: &impl AsColumnFamilyRef, name: impl CStrLike, ) -> Result<Option<u64>, Error>

pub fn get_pinned_cf_opt<K: AsRef<[u8]>>( &self, cf: &impl AsColumnFamilyRef, key: K, readopts: &ReadOptions, ) -> Result<Option<DBPinnableSlice<'_>>, Error>

pub fn cf_handle(&self, name: &str) -> Option<Arc<BoundColumnFamily<'_>>>

pub fn create_cf<N: AsRef<str>>( &self, name: N, opts: &Options, ) -> Result<(), Error>

pub fn drop_cf(&self, name: &str) -> Result<(), Error>

pub fn delete_file_in_range<K: AsRef<[u8]>>( &self, cf: &impl AsColumnFamilyRef, from: K, to: K, ) -> Result<(), Error>

pub fn delete_cf<K: AsRef<[u8]>>( &self, cf: &impl AsColumnFamilyRef, key: K, writeopts: &WriteOptions, ) -> Result<(), Error>

pub fn path(&self) -> &Path

pub fn put_cf<K, V>( &self, cf: &impl AsColumnFamilyRef, key: K, value: V, writeopts: &WriteOptions, ) -> Result<(), Error>

where K: AsRef<[u8]>, V: AsRef<[u8]>,

pub fn key_may_exist_cf<K: AsRef<[u8]>>( &self, cf: &impl AsColumnFamilyRef, key: K, readopts: &ReadOptions, ) -> bool

pub fn try_catch_up_with_primary(&self) -> Result<(), Error>

pub fn write( &self, batch: RocksDBBatch, writeopts: &WriteOptions, ) -> Result<(), TypedStoreError>

pub fn transaction_without_snapshot( &self, ) -> Result<Transaction<'_, OptimisticTransactionDB>, TypedStoreError>

pub fn transaction( &self, ) -> Result<Transaction<'_, OptimisticTransactionDB>, TypedStoreError>

pub fn raw_iterator_cf<'a: 'b, 'b>( &'a self, cf_handle: &impl AsColumnFamilyRef, readopts: ReadOptions, ) -> RocksDBRawIter<'b>

pub fn iterator_cf<'a: 'b, 'b>( &'a self, cf_handle: &impl AsColumnFamilyRef, readopts: ReadOptions, mode: IteratorMode<'_>, ) -> RocksDBIter<'b>

pub fn compact_range_cf<K: AsRef<[u8]>>( &self, cf: &impl AsColumnFamilyRef, start: Option<K>, end: Option<K>, )

pub fn compact_range_to_bottom<K: AsRef<[u8]>>( &self, cf: &impl AsColumnFamilyRef, start: Option<K>, end: Option<K>, )

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

pub fn snapshot(&self) -> RocksDBSnapshot<'_>

pub fn checkpoint(&self, path: &Path) -> Result<(), TypedStoreError>

pub fn flush_cf(&self, cf: &impl AsColumnFamilyRef) -> Result<(), Error>

pub fn set_options_cf( &self, cf: &impl AsColumnFamilyRef, opts: &[(&str, &str)], ) -> Result<(), Error>

pub fn get_sampling_interval(&self) -> SamplingInterval

pub fn multiget_sampling_interval(&self) -> SamplingInterval

pub fn write_sampling_interval(&self) -> SamplingInterval

pub fn iter_sampling_interval(&self) -> SamplingInterval

pub fn db_name(&self) -> String

pub fn live_files(&self) -> Result<Vec<LiveFile>, Error>

Trait Implementations

impl Debug for RocksDB

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

Formats the value using the given formatter.

impl Drop for RocksDB

fn drop(&mut self)

Executes the destructor for this type.