Struct ckb_rocksdb::TransactionDB

pub struct TransactionDB { /* fields omitted */ }

A transaction database.

Methods

impl TransactionDB

pub fn path(&self) -> &Path

impl TransactionDB

pub fn snapshot(&self) -> Snapshot

Trait Implementations

impl CreateCf for TransactionDB

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

impl CreateCheckpointObject for TransactionDB

unsafe fn create_checkpoint_object_raw(
    &self
) -> Result<*mut rocksdb_checkpoint_t, Error>

fn create_checkpoint_object(&self) -> Result<Checkpoint, Error>

impl DeleteCF<WriteOptions> for TransactionDB

fn delete_cf_full<K>(
    &self,
    cf: Option<&ColumnFamily>,
    key: K,
    writeopts: Option<&WriteOptions>
) -> Result<(), Error> where
    K: AsRef<[u8]>, 

fn delete_cf<K>(&self, cf: &ColumnFamily, key: K) -> Result<(), Error> where
    K: AsRef<[u8]>, 

fn put_cf_opt<K>(
    &self,
    cf: &ColumnFamily,
    key: K,
    writeopts: &W
) -> Result<(), Error> where
    K: AsRef<[u8]>, 

impl Drop for TransactionDB

fn drop(&mut self)

Executes the destructor for this type.

impl GetCF<ReadOptions> for TransactionDB

fn get_cf_full<K: AsRef<[u8]>>(
    &self,
    cf: Option<&ColumnFamily>,
    key: K,
    readopts: Option<&ReadOptions>
) -> Result<Option<DBVector>, Error>

fn get_cf<K: AsRef<[u8]>>(
    &self,
    cf: &ColumnFamily,
    key: K
) -> Result<Option<DBVector>, Error>

fn get_cf_opt<K: AsRef<[u8]>>(
    &self,
    cf: &ColumnFamily,
    key: K,
    readopts: &R
) -> Result<Option<DBVector>, Error>

impl GetColumnFamilys for TransactionDB

fn get_cfs(&self) -> &BTreeMap<String, ColumnFamily>

fn get_mut_cfs(&mut self) -> &mut BTreeMap<String, ColumnFamily>

fn cf_handle(&self, name: &str) -> Option<&ColumnFamily>

Return the underlying column family handle.

impl Handle<rocksdb_transactiondb_t> for TransactionDB

fn handle(&self) -> *mut rocksdb_transactiondb_t

impl Iterate for TransactionDB

fn get_raw_iter(&self, readopts: &ReadOptions) -> DBRawIterator

Important traits for DBIterator<'a>

impl<'a> Iterator for DBIterator<'a> type Item = (Box<[u8]>, Box<[u8]>);

fn get_iter(&self, readopts: &ReadOptions, mode: IteratorMode) -> DBIterator

Important traits for DBIterator<'a>

impl<'a> Iterator for DBIterator<'a> type Item = (Box<[u8]>, Box<[u8]>);

fn iterator_opt(&self, mode: IteratorMode, readopts: &ReadOptions) -> DBIterator

Important traits for DBIterator<'a>

impl<'a> Iterator for DBIterator<'a> type Item = (Box<[u8]>, Box<[u8]>);

fn iterator(&self, mode: IteratorMode) -> DBIterator

Important traits for DBIterator<'a>

impl<'a> Iterator for DBIterator<'a> type Item = (Box<[u8]>, Box<[u8]>);

fn full_iterator(&self, mode: IteratorMode) -> DBIterator

Opens an interator with set_total_order_seek enabled. This must be used to iterate across prefixes when set_memtable_factory has been called with a Hash-based implementation.

Important traits for DBIterator<'a>

impl<'a> Iterator for DBIterator<'a> type Item = (Box<[u8]>, Box<[u8]>);

fn prefix_iterator(&self, prefix: &[u8]) -> DBIterator

fn raw_iterator(&self) -> DBRawIterator

impl IterateCF for TransactionDB

fn get_raw_iter_cf(
    &self,
    cf_handle: &ColumnFamily,
    readopts: &ReadOptions
) -> Result<DBRawIterator, Error>

fn get_iter_cf(
    &self,
    cf_handle: &ColumnFamily,
    readopts: &ReadOptions,
    mode: IteratorMode
) -> Result<DBIterator, Error>

fn iterator_cf_opt(
    &self,
    cf_handle: &ColumnFamily,
    mode: IteratorMode,
    readopts: &ReadOptions
) -> Result<DBIterator, Error>

Opens an interator using the provided ReadOptions. This is used when you want to iterate over a specific ColumnFamily with a modified ReadOptions

fn iterator_cf(
    &self,
    cf_handle: &ColumnFamily,
    mode: IteratorMode
) -> Result<DBIterator, Error>

fn full_iterator_cf(
    &self,
    cf_handle: &ColumnFamily,
    mode: IteratorMode
) -> Result<DBIterator, Error>

fn prefix_iterator_cf(
    &self,
    cf_handle: &ColumnFamily,
    prefix: &[u8]
) -> Result<DBIterator, Error>

fn raw_iterator_cf(
    &self,
    cf_handle: &ColumnFamily
) -> Result<DBRawIterator, Error>

impl MergeCF<WriteOptions> for TransactionDB

fn merge_cf_full<K, V>(
    &self,
    cf: Option<&ColumnFamily>,
    key: K,
    value: V,
    writeopts: Option<&WriteOptions>
) -> Result<(), Error> where
    K: AsRef<[u8]>,
    V: AsRef<[u8]>, 

fn merge_cf<K, V>(
    &self,
    cf: &ColumnFamily,
    key: K,
    value: V
) -> Result<(), Error> where
    K: AsRef<[u8]>,
    V: AsRef<[u8]>, 

fn merge_cf_opt<K, V>(
    &self,
    cf: &ColumnFamily,
    key: K,
    value: V,
    writeopts: &W
) -> Result<(), Error> where
    K: AsRef<[u8]>,
    V: AsRef<[u8]>, 

impl Open for TransactionDB

fn open_default<P: AsRef<Path>>(path: P) -> Result<Self, Error>

Open a database with default options.

fn open<P: AsRef<Path>>(opts: &Options, path: P) -> Result<Self, Error>

Open the database with the specified options.

fn open_with_descriptor<P: AsRef<Path>>(
    opts: &Options,
    path: P,
    descriptor: Self::Descriptor
) -> Result<Self, Error>

impl PutCF<WriteOptions> for TransactionDB

fn put_cf_full<K, V>(
    &self,
    cf: Option<&ColumnFamily>,
    key: K,
    value: V,
    writeopts: Option<&WriteOptions>
) -> Result<(), Error> where
    K: AsRef<[u8]>,
    V: AsRef<[u8]>, 

fn put_cf<K, V>(&self, cf: &ColumnFamily, key: K, value: V) -> Result<(), Error> where
    K: AsRef<[u8]>,
    V: AsRef<[u8]>, 

fn put_cf_opt<K, V>(
    &self,
    cf: &ColumnFamily,
    key: K,
    value: V,
    writeopts: &W
) -> Result<(), Error> where
    K: AsRef<[u8]>,
    V: AsRef<[u8]>, 

impl Read for TransactionDB

impl Send for TransactionDB

impl Sync for TransactionDB

impl TransactionBegin for TransactionDB

type WriteOptions = WriteOptions

type TransactionOptions = TransactionOptions

fn transaction(
    &self,
    write_options: &WriteOptions,
    tx_options: &TransactionOptions
) -> Transaction<TransactionDB>

fn transaction_default(&self) -> Transaction<Self>

Begins a new optimistic transaction with default options.

impl Write for TransactionDB

impl WriteOps for TransactionDB

fn write_full(
    &self,
    batch: WriteBatch,
    writeopts: Option<&WriteOptions>
) -> Result<(), Error>

fn write(&self, batch: WriteBatch) -> Result<(), Error>

fn write_opt(
    &self,
    batch: WriteBatch,
    writeopts: &WriteOptions
) -> Result<(), Error>

fn write_without_wal(&self, batch: WriteBatch) -> Result<(), Error>