Struct rocksdb::SnapshotWithThreadMode

source ·
pub struct SnapshotWithThreadMode<'a, D: DBAccess> { /* private fields */ }
Expand description

A consistent view of the database at the point of creation.

§Examples

use rocksdb::{DB, IteratorMode, Options};

let path = "_path_for_rocksdb_storage3";
{
    let db = DB::open_default(path).unwrap();
    let snapshot = db.snapshot(); // Creates a longer-term snapshot of the DB, but closed when goes out of scope
    let mut iter = snapshot.iterator(IteratorMode::Start); // Make as many iterators as you'd like from one snapshot
}
let _ = DB::destroy(&Options::default(), path);

Implementations§

source§

impl<'a, D: DBAccess> SnapshotWithThreadMode<'a, D>

source

pub fn new(db: &'a D) -> Self

Creates a new SnapshotWithThreadMode of the database db.

source

pub fn iterator( &self, mode: IteratorMode<'_>, ) -> DBIteratorWithThreadMode<'a, D>

Creates an iterator over the data in this snapshot, using the default read options.

source

pub fn iterator_cf( &self, cf_handle: &impl AsColumnFamilyRef, mode: IteratorMode<'_>, ) -> DBIteratorWithThreadMode<'_, D>

Creates an iterator over the data in this snapshot under the given column family, using the default read options.

source

pub fn iterator_opt( &self, mode: IteratorMode<'_>, readopts: ReadOptions, ) -> DBIteratorWithThreadMode<'a, D>

Creates an iterator over the data in this snapshot, using the given read options.

source

pub fn iterator_cf_opt( &self, cf_handle: &impl AsColumnFamilyRef, readopts: ReadOptions, mode: IteratorMode<'_>, ) -> DBIteratorWithThreadMode<'_, D>

Creates an iterator over the data in this snapshot under the given column family, using the given read options.

source

pub fn raw_iterator(&self) -> DBRawIteratorWithThreadMode<'_, D>

Creates a raw iterator over the data in this snapshot, using the default read options.

source

pub fn raw_iterator_cf( &self, cf_handle: &impl AsColumnFamilyRef, ) -> DBRawIteratorWithThreadMode<'_, D>

Creates a raw iterator over the data in this snapshot under the given column family, using the default read options.

source

pub fn raw_iterator_opt( &self, readopts: ReadOptions, ) -> DBRawIteratorWithThreadMode<'_, D>

Creates a raw iterator over the data in this snapshot, using the given read options.

source

pub fn raw_iterator_cf_opt( &self, cf_handle: &impl AsColumnFamilyRef, readopts: ReadOptions, ) -> DBRawIteratorWithThreadMode<'_, D>

Creates a raw iterator over the data in this snapshot under the given column family, using the given read options.

source

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

Returns the bytes associated with a key value with default read options.

source

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

Returns the bytes associated with a key value and given column family with default read options.

source

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

Returns the bytes associated with a key value and given read options.

source

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

Returns the bytes associated with a key value, given column family and read options.

source

pub fn get_pinned<K: AsRef<[u8]>>( &self, key: K, ) -> Result<Option<DBPinnableSlice<'_>>, Error>

Return the value associated with a key using RocksDB’s PinnableSlice so as to avoid unnecessary memory copy. Similar to get_pinned_opt but leverages default options.

source

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

Return the value associated with a key using RocksDB’s PinnableSlice so as to avoid unnecessary memory copy. Similar to get_pinned_cf_opt but leverages default options.

source

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

Return the value associated with a key using RocksDB’s PinnableSlice so as to avoid unnecessary memory copy.

source

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

Return the value associated with a key using RocksDB’s PinnableSlice so as to avoid unnecessary memory copy. Similar to get_pinned_opt but allows specifying ColumnFamily.

source

pub fn multi_get<K: AsRef<[u8]>, I>( &self, keys: I, ) -> Vec<Result<Option<Vec<u8>>, Error>>
where I: IntoIterator<Item = K>,

Returns the bytes associated with the given key values and default read options.

source

pub fn multi_get_cf<'b, K, I, W>( &self, keys_cf: I, ) -> Vec<Result<Option<Vec<u8>>, Error>>
where K: AsRef<[u8]>, I: IntoIterator<Item = (&'b W, K)>, W: AsColumnFamilyRef + 'b,

Returns the bytes associated with the given key values and default read options.

source

pub fn multi_get_opt<K, I>( &self, keys: I, readopts: ReadOptions, ) -> Vec<Result<Option<Vec<u8>>, Error>>
where K: AsRef<[u8]>, I: IntoIterator<Item = K>,

Returns the bytes associated with the given key values and given read options.

source

pub fn multi_get_cf_opt<'b, K, I, W>( &self, keys_cf: I, readopts: ReadOptions, ) -> Vec<Result<Option<Vec<u8>>, Error>>
where K: AsRef<[u8]>, I: IntoIterator<Item = (&'b W, K)>, W: AsColumnFamilyRef + 'b,

Returns the bytes associated with the given key values, given column family and read options.

Trait Implementations§

source§

impl<'a, D: DBAccess> Drop for SnapshotWithThreadMode<'a, D>

source§

fn drop(&mut self)

Executes the destructor for this type. Read more
source§

impl<'a, D: DBAccess> Send for SnapshotWithThreadMode<'a, D>

Send and Sync implementations for SnapshotWithThreadMode are safe, because SnapshotWithThreadMode is immutable and can be safely shared between threads.

source§

impl<'a, D: DBAccess> Sync for SnapshotWithThreadMode<'a, D>

Auto Trait Implementations§

§

impl<'a, D> Freeze for SnapshotWithThreadMode<'a, D>

§

impl<'a, D> RefUnwindSafe for SnapshotWithThreadMode<'a, D>
where D: RefUnwindSafe,

§

impl<'a, D> Unpin for SnapshotWithThreadMode<'a, D>

§

impl<'a, D> UnwindSafe for SnapshotWithThreadMode<'a, D>
where D: RefUnwindSafe,

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.