Struct tikv::storage::kv::RocksSnapshot

pub struct RocksSnapshot {
    db: Arc<DB>,
    snap: UnsafeSnap,
}

Fields

db: Arc<DB>

snap: UnsafeSnap

Implementations

impl RocksSnapshot

pub fn new(db: Arc<DB>) -> RocksSnapshot

Trait Implementations

impl Debug for RocksSnapshot

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

Formats the value using the given formatter.

impl Drop for RocksSnapshot

pub fn drop(&mut self)

Executes the destructor for this type.

impl Iterable for RocksSnapshot

type Iterator = RocksEngineIterator

pub fn iterator_opt(
    &self,
    opts: IterOptions
) -> Result<<RocksSnapshot as Iterable>::Iterator, Error>

pub fn iterator_cf_opt(
    &self,
    cf: &str,
    opts: IterOptions
) -> Result<<RocksSnapshot as Iterable>::Iterator, Error>

pub fn iterator(&self) -> Result<Self::Iterator, Error>

pub fn iterator_cf(&self, cf: &str) -> Result<Self::Iterator, Error>

pub fn scan<F>(
    &self,
    start_key: &[u8],
    end_key: &[u8],
    fill_cache: bool,
    f: F
) -> Result<(), Error> where
    F: FnMut(&[u8], &[u8]) -> Result<bool, Error>, 

pub fn scan_cf<F>(
    &self,
    cf: &str,
    start_key: &[u8],
    end_key: &[u8],
    fill_cache: bool,
    f: F
) -> Result<(), Error> where
    F: FnMut(&[u8], &[u8]) -> Result<bool, Error>, 

pub fn seek(
    &self,
    key: &[u8]
) -> Result<Option<(Vec<u8, Global>, Vec<u8, Global>)>, Error>

pub fn seek_cf(
    &self,
    cf: &str,
    key: &[u8]
) -> Result<Option<(Vec<u8, Global>, Vec<u8, Global>)>, Error>

impl Peekable for RocksSnapshot

type DBVector = RocksDBVector

The byte-vector type through which the database returns read values.

pub fn get_value_opt(
    &self,
    opts: &ReadOptions,
    key: &[u8]
) -> Result<Option<RocksDBVector>, Error>

Read a value for a key, given a set of options.

pub fn get_value_cf_opt(
    &self,
    opts: &ReadOptions,
    cf: &str,
    key: &[u8]
) -> Result<Option<RocksDBVector>, Error>

Read a value for a key from a given column family, given a set of options.

pub fn get_value(&self, key: &[u8]) -> Result<Option<Self::DBVector>, Error>

Read a value for a key.

pub fn get_value_cf(
    &self,
    cf: &str,
    key: &[u8]
) -> Result<Option<Self::DBVector>, Error>

Read a value for a key from a given column family.

pub fn get_msg<M>(&self, key: &[u8]) -> Result<Option<M>, Error> where
    M: Message + Default, 

Read a value and return it as a protobuf message.

pub fn get_msg_cf<M>(&self, cf: &str, key: &[u8]) -> Result<Option<M>, Error> where
    M: Message + Default, 

Read a value and return it as a protobuf message.

impl Send for RocksSnapshot

impl Snapshot for RocksSnapshot

pub fn cf_names(&self) -> Vec<&str, Global>

impl Sync for RocksSnapshot