Struct serai_coordinator::tributary::db::ParityDb

pub struct ParityDb {
    inner: Arc<DbInner>,
    commit_thread: Option<JoinHandle<()>>,
    flush_thread: Option<JoinHandle<()>>,
    log_thread: Option<JoinHandle<()>>,
    cleanup_thread: Option<JoinHandle<()>>,
}

Database instance.

Fields

inner: Arc<DbInner>

commit_thread: Option<JoinHandle<()>>

flush_thread: Option<JoinHandle<()>>

log_thread: Option<JoinHandle<()>>

cleanup_thread: Option<JoinHandle<()>>

Implementations

impl Db

pub fn open(options: &Options) -> Result<Db, Error>

Open the database with given options. An error will be returned if the database does not exist.

pub fn open_or_create(options: &Options) -> Result<Db, Error>

Open the database using given options. If the database does not exist it will be created empty.

pub fn open_read_only(options: &Options) -> Result<Db, Error>

Open an existing database in read-only mode.

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

Get a value in a specified column by key. Returns None if the key does not exist.

pub fn get_size(&self, col: u8, key: &[u8]) -> Result<Option<u32>, Error>

Get value size by key. Returns None if the key does not exist.

pub fn iter(&self, col: u8) -> Result<BTreeIterator<'_>, Error>

Iterate over all ordered key-value pairs. Only supported for columns configured with btree_indexed.

pub fn commit<I, K>(&self, tx: I) -> Result<(), Error>

where I: IntoIterator<Item = (u8, K, Option<Vec<u8>>)>, K: AsRef<[u8]>,

Commit a set of changes to the database.

pub fn commit_changes<I>(&self, tx: I) -> Result<(), Error>

where I: IntoIterator<Item = (u8, Operation<Vec<u8>, Vec<u8>>)>,

Commit a set of changes to the database.

pub fn num_columns(&self) -> u8

Returns the number of columns in the database.

pub fn iter_column_while( &self, c: u8, f: impl FnMut(ValueIterState) -> bool, ) -> Result<(), Error>

Iterate a column and call a function for each value. This is only supported for columns with btree_index set to false. Iteration order is unspecified. Unlike get the iteration may not include changes made in recent commit calls.

pub fn write_stats_text( &self, writer: &mut impl Write, column: Option<u8>, ) -> Result<(), Error>

Dump full database stats to the text output.

pub fn clear_stats(&self, column: Option<u8>) -> Result<(), Error>

Reset internal database statistics for the database or specified column.

pub fn dump(&self, check_param: CheckOptions) -> Result<(), Error>

Print database contents in text form to stderr.

pub fn stats(&self) -> StatSummary

Get database statistics.

pub fn add_column( options: &mut Options, new_column_options: ColumnOptions, ) -> Result<(), Error>

Add a new column with options specified by new_column_options.

pub fn drop_last_column(options: &mut Options) -> Result<(), Error>

Remove last column from the database. Db must be close when called.

pub fn reset_column( options: &mut Options, index: u8, new_options: Option<ColumnOptions>, ) -> Result<(), Error>

Truncate a column from the database, optionally changing its options. Db must be close when called.

Trait Implementations

impl Drop for Db

fn drop(&mut self)

Executes the destructor for this type.