Trait sc_client_api::backend::StateBackend

pub trait StateBackend<H>: Debugwhere
    H: Hasher,{
    type Error: Error;
    type Transaction: Consolidate + Default + Send;
    type TrieBackendStorage: TrieBackendStorage<H, Overlay = Self::Transaction>;

    fn storage(&self, key: &[u8]) -> Result<Option<Vec<u8, Global>>, Self::Error>;
    fn storage_hash(
        &self,
        key: &[u8]
    ) -> Result<Option<<H as Hasher>::Out>, Self::Error>;
    fn child_storage(
        &self,
        child_info: &ChildInfo,
        key: &[u8]
    ) -> Result<Option<Vec<u8, Global>>, Self::Error>;
    fn child_storage_hash(
        &self,
        child_info: &ChildInfo,
        key: &[u8]
    ) -> Result<Option<<H as Hasher>::Out>, Self::Error>;
    fn next_storage_key(
        &self,
        key: &[u8]
    ) -> Result<Option<Vec<u8, Global>>, Self::Error>;
    fn next_child_storage_key(
        &self,
        child_info: &ChildInfo,
        key: &[u8]
    ) -> Result<Option<Vec<u8, Global>>, Self::Error>;
    fn apply_to_key_values_while<F>(
        &self,
        child_info: Option<&ChildInfo>,
        prefix: Option<&[u8]>,
        start_at: Option<&[u8]>,
        f: F,
        allow_missing: bool
    ) -> Result<bool, Self::Error>
    where
        F: FnMut(Vec<u8, Global>, Vec<u8, Global>) -> bool;
    fn apply_to_keys_while<F>(
        &self,
        child_info: Option<&ChildInfo>,
        prefix: Option<&[u8]>,
        start_at: Option<&[u8]>,
        f: F
    )
    where
        F: FnMut(&[u8]) -> bool;
    fn for_key_values_with_prefix<F>(&self, prefix: &[u8], f: F)
    where
        F: FnMut(&[u8], &[u8]);
    fn for_child_keys_with_prefix<F>(
        &self,
        child_info: &ChildInfo,
        prefix: &[u8],
        f: F
    )
    where
        F: FnMut(&[u8]);
    fn storage_root<'a>(
        &self,
        delta: impl Iterator<Item = (&'a [u8], Option<&'a [u8]>)>,
        state_version: StateVersion
    ) -> (<H as Hasher>::Out, Self::Transaction)
    where
        <H as Hasher>::Out: Ord;
    fn child_storage_root<'a>(
        &self,
        child_info: &ChildInfo,
        delta: impl Iterator<Item = (&'a [u8], Option<&'a [u8]>)>,
        state_version: StateVersion
    ) -> (<H as Hasher>::Out, bool, Self::Transaction)
    where
        <H as Hasher>::Out: Ord;
    fn pairs(&self) -> Vec<(Vec<u8, Global>, Vec<u8, Global>), Global> ;
    fn register_overlay_stats(&self, _stats: &StateMachineStats);
    fn usage_info(&self) -> UsageInfo;

    fn exists_storage(&self, key: &[u8]) -> Result<bool, Self::Error> { ... }
    fn exists_child_storage(
        &self,
        child_info: &ChildInfo,
        key: &[u8]
    ) -> Result<bool, Self::Error> { ... }
    fn for_keys_with_prefix<F>(&self, prefix: &[u8], f: F)
    where
        F: FnMut(&[u8]),
    { ... }
    fn keys(&self, prefix: &[u8]) -> Vec<Vec<u8, Global>, Global>  { ... }
    fn child_keys(
        &self,
        child_info: &ChildInfo,
        prefix: &[u8]
    ) -> Vec<Vec<u8, Global>, Global>  { ... }
    fn full_storage_root<'a>(
        &self,
        delta: impl Iterator<Item = (&'a [u8], Option<&'a [u8]>)>,
        child_deltas: impl Iterator<Item = (&'a ChildInfo, impl Iterator<Item = (&'a [u8], Option<&'a [u8]>)>)>,
        state_version: StateVersion
    ) -> (<H as Hasher>::Out, Self::Transaction)
    where
        <H as Hasher>::Out: Ord + Encode,
    { ... }
    fn wipe(&self) -> Result<(), Self::Error> { ... }
    fn commit(
        &self,
        _: <H as Hasher>::Out,
        _: Self::Transaction,
        _: Vec<(Vec<u8, Global>, Option<Vec<u8, Global>>), Global>,
        _: Vec<(Vec<u8, Global>, Vec<(Vec<u8, Global>, Option<Vec<u8, Global>>), Global>), Global>
    ) -> Result<(), Self::Error> { ... }
    fn read_write_count(&self) -> (u32, u32, u32, u32) { ... }
    fn reset_read_write_count(&self) { ... }
    fn get_whitelist(&self) -> Vec<TrackedStorageKey, Global>  { ... }
    fn set_whitelist(&self, _: Vec<TrackedStorageKey, Global>) { ... }
    fn proof_size(&self) -> Option<u32> { ... }
    fn get_read_and_written_keys(
        &self
    ) -> Vec<(Vec<u8, Global>, u32, u32, bool), Global>  { ... }
}

A state backend is used to read state data and can have changes committed to it.

The clone operation (if implemented) should be cheap.

Required Associated Types

type Error: Error

An error type when fetching data is not possible.

type Transaction: Consolidate + Default + Send

Storage changes to be applied if committing

type TrieBackendStorage: TrieBackendStorage<H, Overlay = Self::Transaction>

Type of trie backend storage.

Required Methods

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

Get keyed storage or None if there is nothing associated.

fn storage_hash(
&self,
key: &[u8]
) -> Result<Option<<H as Hasher>::Out>, Self::Error>

Get keyed storage value hash or None if there is nothing associated.

fn child_storage(
&self,
child_info: &ChildInfo,
key: &[u8]
) -> Result<Option<Vec<u8, Global>>, Self::Error>

Get keyed child storage or None if there is nothing associated.

fn child_storage_hash(
&self,
child_info: &ChildInfo,
key: &[u8]
) -> Result<Option<<H as Hasher>::Out>, Self::Error>

Get child keyed storage value hash or None if there is nothing associated.

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

Return the next key in storage in lexicographic order or None if there is no value.

fn next_child_storage_key(
&self,
child_info: &ChildInfo,
key: &[u8]
) -> Result<Option<Vec<u8, Global>>, Self::Error>

Return the next key in child storage in lexicographic order or None if there is no value.

fn apply_to_key_values_while<F>(
&self,
child_info: Option<&ChildInfo>,
prefix: Option<&[u8]>,
start_at: Option<&[u8]>,
f: F,
allow_missing: bool
) -> Result<bool, Self::Error>where
F: FnMut(Vec<u8, Global>, Vec<u8, Global>) -> bool,

Iterate over storage starting at key, for a given prefix and child trie. Aborts as soon as f returns false. Warning, this fails at first error when usual iteration skips errors. If allow_missing is true, iteration stops when it reaches a missing trie node. Otherwise an error is produced.

Returns true if trie end is reached.

fn apply_to_keys_while<F>(
&self,
child_info: Option<&ChildInfo>,
prefix: Option<&[u8]>,
start_at: Option<&[u8]>,
f: F
)where
F: FnMut(&[u8]) -> bool,

Retrieve all entries keys of storage and call f for each of those keys. Aborts as soon as f returns false.

fn for_key_values_with_prefix<F>(&self, prefix: &[u8], f: F)where
F: FnMut(&[u8], &[u8]),

Retrieve all entries keys and values of which start with the given prefix and call f for each of those keys.

fn for_child_keys_with_prefix<F>(
&self,
child_info: &ChildInfo,
prefix: &[u8],
f: F
)where
F: FnMut(&[u8]),

Retrieve all child entries keys which start with the given prefix and call f for each of those keys.

fn storage_root<'a>(
&self,
delta: impl Iterator<Item = (&'a [u8], Option<&'a [u8]>)>,
state_version: StateVersion
) -> (<H as Hasher>::Out, Self::Transaction)where
<H as Hasher>::Out: Ord,

Calculate the storage root, with given delta over what is already stored in the backend, and produce a “transaction” that can be used to commit. Does not include child storage updates.

fn child_storage_root<'a>(
&self,
child_info: &ChildInfo,
delta: impl Iterator<Item = (&'a [u8], Option<&'a [u8]>)>,
state_version: StateVersion
) -> (<H as Hasher>::Out, bool, Self::Transaction)where
<H as Hasher>::Out: Ord,

Calculate the child storage root, with given delta over what is already stored in the backend, and produce a “transaction” that can be used to commit. The second argument is true if child storage root equals default storage root.

fn pairs(&self) -> Vec<(Vec<u8, Global>, Vec<u8, Global>), Global>

Get all key/value pairs into a Vec.

fn register_overlay_stats(&self, _stats: &StateMachineStats)

Register stats from overlay of state machine.

By default nothing is registered.

fn usage_info(&self) -> UsageInfo

Query backend usage statistics (i/o, memory)

Not all implementations are expected to be able to do this. In the case when they don’t, empty statistics is returned.

Provided Methods

fn exists_storage(&self, key: &[u8]) -> Result<bool, Self::Error>

true if a key exists in storage.

fn exists_child_storage(
&self,
child_info: &ChildInfo,
key: &[u8]
) -> Result<bool, Self::Error>

true if a key exists in child storage.

fn for_keys_with_prefix<F>(&self, prefix: &[u8], f: F)where
F: FnMut(&[u8]),

Retrieve all entries keys which start with the given prefix and call f for each of those keys.

fn keys(&self, prefix: &[u8]) -> Vec<Vec<u8, Global>, Global>

Get all keys with given prefix

fn child_keys(
&self,
child_info: &ChildInfo,
prefix: &[u8]
) -> Vec<Vec<u8, Global>, Global>

Get all keys of child storage with given prefix

fn full_storage_root<'a>(
&self,
delta: impl Iterator<Item = (&'a [u8], Option<&'a [u8]>)>,
child_deltas: impl Iterator<Item = (&'a ChildInfo, impl Iterator<Item = (&'a [u8], Option<&'a [u8]>)>)>,
state_version: StateVersion
) -> (<H as Hasher>::Out, Self::Transaction)where
<H as Hasher>::Out: Ord + Encode,

Calculate the storage root, with given delta over what is already stored in the backend, and produce a “transaction” that can be used to commit. Does include child storage updates.

fn wipe(&self) -> Result<(), Self::Error>

Wipe the state database.

fn commit(
&self,
_: <H as Hasher>::Out,
_: Self::Transaction,
_: Vec<(Vec<u8, Global>, Option<Vec<u8, Global>>), Global>,
_: Vec<(Vec<u8, Global>, Vec<(Vec<u8, Global>, Option<Vec<u8, Global>>), Global>), Global>
) -> Result<(), Self::Error>

Commit given transaction to storage.

fn read_write_count(&self) -> (u32, u32, u32, u32)

Get the read/write count of the db

fn reset_read_write_count(&self)

Get the read/write count of the db

fn get_whitelist(&self) -> Vec<TrackedStorageKey, Global>

Get the whitelist for tracking db reads/writes

fn set_whitelist(&self, _: Vec<TrackedStorageKey, Global>)

Update the whitelist for tracking db reads/writes

fn proof_size(&self) -> Option<u32>

Estimate proof size

fn get_read_and_written_keys(
&self
) -> Vec<(Vec<u8, Global>, u32, u32, bool), Global>

Extend storage info for benchmarking db

Implementors

impl<S, H, C> Backend<H> for TrieBackend<S, H, C>where
S: TrieBackendStorage<H>,
H: Hasher,
C: AsLocalTrieCache<H> + Send + Sync,
<H as Hasher>::Out: Ord + Codec,

type Error = String

type Transaction = <S as TrieBackendStorage<H>>::Overlay

type TrieBackendStorage = S