Trait polkadot_node_subsystem_util::database::KeyValueDB

pub trait KeyValueDB: Sync + Send {
    // Required methods
    fn get(&self, col: u32, key: &[u8]) -> Result<Option<Vec<u8>>, Error>;
    fn get_by_prefix(
        &self,
        col: u32,
        prefix: &[u8],
    ) -> Result<Option<Vec<u8>>, Error>;
    fn write(&self, transaction: DBTransaction) -> Result<(), Error>;
    fn iter<'a>(
        &'a self,
        col: u32,
    ) -> Box<dyn Iterator<Item = Result<(SmallVec<[u8; 32]>, Vec<u8>), Error>> + 'a>;
    fn iter_with_prefix<'a>(
        &'a self,
        col: u32,
        prefix: &'a [u8],
    ) -> Box<dyn Iterator<Item = Result<(SmallVec<[u8; 32]>, Vec<u8>), Error>> + 'a>;

    // Provided methods
    fn transaction(&self) -> DBTransaction { ... }
    fn io_stats(&self, _kind: Kind) -> IoStats { ... }
    fn has_key(&self, col: u32, key: &[u8]) -> Result<bool, Error> { ... }
    fn has_prefix(&self, col: u32, prefix: &[u8]) -> Result<bool, Error> { ... }
}

Generic key-value database.

The KeyValueDB deals with “column families”, which can be thought of as distinct stores within a database. Keys written in one column family will not be accessible from any other. The number of column families must be specified at initialization, with a differing interface for each database.

The API laid out here, along with the Sync bound implies interior synchronization for implementation.

Required Methods

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

Get a value by key.

fn get_by_prefix( &self, col: u32, prefix: &[u8], ) -> Result<Option<Vec<u8>>, Error>

Get the first value matching the given prefix.

fn write(&self, transaction: DBTransaction) -> Result<(), Error>

Write a transaction of changes to the backing store.

fn iter<'a>( &'a self, col: u32, ) -> Box<dyn Iterator<Item = Result<(SmallVec<[u8; 32]>, Vec<u8>), Error>> + 'a>

Iterate over the data for a given column.

fn iter_with_prefix<'a>( &'a self, col: u32, prefix: &'a [u8], ) -> Box<dyn Iterator<Item = Result<(SmallVec<[u8; 32]>, Vec<u8>), Error>> + 'a>

Iterate over the data for a given column, returning all key/value pairs where the key starts with the given prefix.

Provided Methods

fn transaction(&self) -> DBTransaction

Helper to create a new transaction.

fn io_stats(&self, _kind: Kind) -> IoStats

Query statistics.

Not all kvdb implementations are able or expected to implement this, so by default, empty statistics is returned. Also, not all kvdb implementations can return every statistic or configured to do so (some statistics gathering may impede the performance and might be off by default).

fn has_key(&self, col: u32, key: &[u8]) -> Result<bool, Error>

Check for the existence of a value by key.

fn has_prefix(&self, col: u32, prefix: &[u8]) -> Result<bool, Error>

Check for the existence of a value by prefix.

Implementations on Foreign Types

impl KeyValueDB for Database

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

fn get_by_prefix( &self, col: u32, prefix: &[u8], ) -> Result<Option<Vec<u8>>, Error>

fn write(&self, transaction: DBTransaction) -> Result<(), Error>

fn iter<'a>( &'a self, col: u32, ) -> Box<dyn Iterator<Item = Result<(SmallVec<[u8; 32]>, Vec<u8>), Error>> + 'a>

fn iter_with_prefix<'a>( &'a self, col: u32, prefix: &'a [u8], ) -> Box<dyn Iterator<Item = Result<(SmallVec<[u8; 32]>, Vec<u8>), Error>> + 'a>

fn io_stats(&self, kind: Kind) -> IoStats

impl KeyValueDB for InMemory

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

fn get_by_prefix( &self, col: u32, prefix: &[u8], ) -> Result<Option<Vec<u8>>, Error>

fn write(&self, transaction: DBTransaction) -> Result<(), Error>

fn iter<'a>( &'a self, col: u32, ) -> Box<dyn Iterator<Item = Result<(SmallVec<[u8; 32]>, Vec<u8>), Error>> + 'a>

fn iter_with_prefix<'a>( &'a self, col: u32, prefix: &'a [u8], ) -> Box<dyn Iterator<Item = Result<(SmallVec<[u8; 32]>, Vec<u8>), Error>> + 'a>

Implementors

impl KeyValueDB for polkadot_node_subsystem_util::database::paritydb_impl::DbAdapter

impl<D: KeyValueDB> KeyValueDB for polkadot_node_subsystem_util::database::kvdb_impl::DbAdapter<D>