Struct WrappedDB 

pub struct WrappedDB<D, T>
where
    D: DB,
{ /* private fields */ }

A tagged newtype wrapper for DBs, to support creating disjoint default storage DBs of the same type, concurrently.

Disjoint default storage for the same DB type are needed, for example, when writing tests that need to run in isolation.

See self::tests::persist_to_disk and self::tests::test_default_storage for example usage.

Implementations

impl<D, T> WrappedDB<D, T>

where D: DB,

pub fn wrap(db: D) -> WrappedDB<D, T>

Create a new WrappedDB from a DB.

Trait Implementations

impl<D, T> Clone for WrappedDB<D, T>

where D: Clone + DB, T: Clone,

fn clone(&self) -> WrappedDB<D, T>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<D, T> DB for WrappedDB<D, T>

where D: DB, T: Sync + Send + 'static,

A pass-thru implementation of DB.

Foot-gun

If the DB trait ever grows another method with a default implementation, we’ll need to be sure to add the pass-thru here, to preserve any possibly overriding implementations provided by the wrapped db.

type Hasher = <D as DB>::Hasher

The hasher used in this DB.

fn get_node( &self, key: &ArenaHash<<WrappedDB<D, T> as DB>::Hasher>, ) -> Option<OnDiskObject<<WrappedDB<D, T> as DB>::Hasher>>

Get node in DAG with key key.

fn get_unreachable_keys( &self, ) -> Vec<ArenaHash<<WrappedDB<D, T> as DB>::Hasher>>

Get the keys for all the unreachable nodes, i.e. the nodes with ref_count == 0, which aren’t marked as GC roots.

fn insert_node( &mut self, key: ArenaHash<<WrappedDB<D, T> as DB>::Hasher>, object: OnDiskObject<<WrappedDB<D, T> as DB>::Hasher>, )

Insert a DAG node with key key.

fn delete_node(&mut self, key: &ArenaHash<<WrappedDB<D, T> as DB>::Hasher>)

Remove the DAG node with key key.

fn get_root_count( &self, key: &ArenaHash<<WrappedDB<D, T> as DB>::Hasher>, ) -> u32

Get the number of times the node with key key has been marked as a GC root. Returns 0 if the node is not a GC root.

fn set_root_count( &mut self, key: ArenaHash<<WrappedDB<D, T> as DB>::Hasher>, count: u32, )

Set the root count of the node with key key to count. If count is 0, the node will no longer be a GC root.

fn get_roots(&self) -> HashMap<ArenaHash<<WrappedDB<D, T> as DB>::Hasher>, u32>

Return a mapping from key to root count, for all the roots in this DB. All mapped root counts will be positive.

fn size(&self) -> usize

Return the number of nodes in this DB.

fn batch_update<I>(&mut self, iter: I)

where I: Iterator<Item = (ArenaHash<<WrappedDB<D, T> as DB>::Hasher>, Update<<WrappedDB<D, T> as DB>::Hasher>)>,

Batch update the database.

fn batch_get_nodes<I>( &self, keys: I, ) -> Vec<(ArenaHash<<WrappedDB<D, T> as DB>::Hasher>, Option<OnDiskObject<<WrappedDB<D, T> as DB>::Hasher>>)>

where I: Iterator<Item = ArenaHash<<WrappedDB<D, T> as DB>::Hasher>>,

Batch get nodes.

fn bfs_get_nodes<C>( &self, key: &ArenaHash<<WrappedDB<D, T> as DB>::Hasher>, cache_get: C, truncate: bool, max_depth: Option<usize>, max_count: Option<usize>, ) -> Vec<(ArenaHash<<WrappedDB<D, T> as DB>::Hasher>, OnDiskObject<<WrappedDB<D, T> as DB>::Hasher>)>

where C: Fn(&ArenaHash<<WrappedDB<D, T> as DB>::Hasher>) -> Option<OnDiskObject<<WrappedDB<D, T> as DB>::Hasher>>,

Get all nodes reachable from the node with key key using a breadth first search.

impl<D, T> Debug for WrappedDB<D, T>

where D: DB + Debug,

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

Formats the value using the given formatter.

impl<D, T> Default for WrappedDB<D, T>

where D: Default + DB,

fn default() -> WrappedDB<D, T>

Returns the “default value” for a type.

impl<D, T> DummyArbitrary for WrappedDB<D, T>

where D: DB + DummyArbitrary,