pub struct MemoryDB<H, KF, T, M = DefaultMemTracker<T>> where
H: KeyHasher,
KF: KeyFunction<H>,
M: MemTracker<T>, { /* private fields */ }
Expand description
Reference-counted memory-based HashDB
implementation.
Use new()
to create a new database. Insert items with insert()
, remove items
with remove()
, check for existence with contains()
and lookup a hash to derive
the data with get()
. Clear with clear()
and purge the portions of the data
that have no references with purge()
.
If you’re not using the MallocSizeOf
implementation to track memory usage,
set the M
type parameter to NoopTracker
.
Example
use hash_db::{Hasher, HashDB, EMPTY_PREFIX};
use keccak_hasher::KeccakHasher;
use memory_db::{MemoryDB, HashKey};
let mut m = MemoryDB::<KeccakHasher, HashKey<_>, Vec<u8>>::default();
let d = "Hello world!".as_bytes();
let k = m.insert(EMPTY_PREFIX, d);
assert!(m.contains(&k, EMPTY_PREFIX));
assert_eq!(m.get(&k, EMPTY_PREFIX).unwrap(), d);
m.insert(EMPTY_PREFIX, d);
assert!(m.contains(&k, EMPTY_PREFIX));
m.remove(&k, EMPTY_PREFIX);
assert!(m.contains(&k, EMPTY_PREFIX));
m.remove(&k, EMPTY_PREFIX);
assert!(!m.contains(&k, EMPTY_PREFIX));
m.remove(&k, EMPTY_PREFIX);
assert!(!m.contains(&k, EMPTY_PREFIX));
m.insert(EMPTY_PREFIX, d);
assert!(!m.contains(&k, EMPTY_PREFIX));
m.insert(EMPTY_PREFIX, d);
assert!(m.contains(&k, EMPTY_PREFIX));
assert_eq!(m.get(&k, EMPTY_PREFIX).unwrap(), d);
m.remove(&k, EMPTY_PREFIX);
assert!(!m.contains(&k, EMPTY_PREFIX));
Implementations
sourceimpl<H, KF, T, M> MemoryDB<H, KF, T, M> where
H: KeyHasher,
T: Default,
KF: KeyFunction<H>,
M: MemTracker<T>,
impl<H, KF, T, M> MemoryDB<H, KF, T, M> where
H: KeyHasher,
T: Default,
KF: KeyFunction<H>,
M: MemTracker<T>,
Create a new MemoryDB
from a given null key/data
sourcepub fn remove_and_purge(
&mut self,
key: &<H as KeyHasher>::Out,
prefix: Prefix<'_>
) -> Option<T>
pub fn remove_and_purge(
&mut self,
key: &<H as KeyHasher>::Out,
prefix: Prefix<'_>
) -> Option<T>
Remove an element and delete it from storage if reference count reaches zero. If the value was purged, return the old value.
sourcepub fn shrink_to_fit(&mut self)
pub fn shrink_to_fit(&mut self)
Shrinks the capacity of the map as much as possible. It will drop down as much as possible while maintaining the internal rules and possibly leaving some space in accordance with the resize policy.
sourceimpl<'a, H, KF, T, M> MemoryDB<H, KF, T, M> where
H: KeyHasher,
T: From<&'a [u8]>,
KF: KeyFunction<H>,
M: MemTracker<T> + Default,
impl<'a, H, KF, T, M> MemoryDB<H, KF, T, M> where
H: KeyHasher,
T: From<&'a [u8]>,
KF: KeyFunction<H>,
M: MemTracker<T> + Default,
sourcepub fn from_null_node(null_key: &'a [u8], null_node_data: T) -> Self
pub fn from_null_node(null_key: &'a [u8], null_node_data: T) -> Self
Create a new MemoryDB
from a given null key/data
sourcepub fn default_with_root() -> (Self, H::Out)
pub fn default_with_root() -> (Self, H::Out)
Create a new default instance of Self
and returns Self
and the root hash.
sourcepub fn clear(&mut self)
pub fn clear(&mut self)
Clear all data from the database.
Examples
extern crate hash_db;
extern crate keccak_hasher;
extern crate memory_db;
use hash_db::{Hasher, HashDB, EMPTY_PREFIX};
use keccak_hasher::KeccakHasher;
use memory_db::{MemoryDB, HashKey};
fn main() {
let mut m = MemoryDB::<KeccakHasher, HashKey<_>, Vec<u8>>::default();
let hello_bytes = "Hello world!".as_bytes();
let hash = m.insert(EMPTY_PREFIX, hello_bytes);
assert!(m.contains(&hash, EMPTY_PREFIX));
m.clear();
assert!(!m.contains(&hash, EMPTY_PREFIX));
}
sourcepub fn drain(&mut self) -> HashMap<KF::Key, (T, i32)>
pub fn drain(&mut self) -> HashMap<KF::Key, (T, i32)>
Return the internal key-value HashMap, clearing the current state.
sourcepub fn raw(
&self,
key: &<H as KeyHasher>::Out,
prefix: Prefix<'_>
) -> Option<(&T, i32)>
pub fn raw(
&self,
key: &<H as KeyHasher>::Out,
prefix: Prefix<'_>
) -> Option<(&T, i32)>
Grab the raw information associated with a key. Returns None if the key doesn’t exist.
Even when Some is returned, the data is only guaranteed to be useful when the refs > 0.
sourcepub fn consolidate(&mut self, other: Self)
pub fn consolidate(&mut self, other: Self)
Consolidate all the entries of other
into self
.
Trait Implementations
sourceimpl<H, KF, T, M> AsHashDB<H, T> for MemoryDB<H, KF, T, M> where
H: KeyHasher,
T: Default + PartialEq<T> + for<'a> From<&'a [u8]> + Clone + Send + Sync,
KF: KeyFunction<H> + Send + Sync,
M: MemTracker<T> + Send + Sync,
impl<H, KF, T, M> AsHashDB<H, T> for MemoryDB<H, KF, T, M> where
H: KeyHasher,
T: Default + PartialEq<T> + for<'a> From<&'a [u8]> + Clone + Send + Sync,
KF: KeyFunction<H> + Send + Sync,
M: MemTracker<T> + Send + Sync,
sourcefn as_hash_db(&self) -> &dyn HashDB<H, T>
fn as_hash_db(&self) -> &dyn HashDB<H, T>
Perform upcast to HashDB for anything that derives from HashDB.
sourcefn as_hash_db_mut(&mut self) -> &mut dyn HashDB<H, T>
fn as_hash_db_mut(&mut self) -> &mut dyn HashDB<H, T>
Perform mutable upcast to HashDB for anything that derives from HashDB.
sourceimpl<H, KF, T, M> AsPlainDB<<H as Hasher>::Out, T> for MemoryDB<H, KF, T, M> where
H: KeyHasher,
T: Default + PartialEq<T> + for<'a> From<&'a [u8]> + Clone + Send + Sync,
KF: KeyFunction<H> + Send + Sync,
KF::Key: Borrow<[u8]> + for<'a> From<&'a [u8]>,
M: MemTracker<T> + Send + Sync,
impl<H, KF, T, M> AsPlainDB<<H as Hasher>::Out, T> for MemoryDB<H, KF, T, M> where
H: KeyHasher,
T: Default + PartialEq<T> + for<'a> From<&'a [u8]> + Clone + Send + Sync,
KF: KeyFunction<H> + Send + Sync,
KF::Key: Borrow<[u8]> + for<'a> From<&'a [u8]>,
M: MemTracker<T> + Send + Sync,
sourcefn as_plain_db(&self) -> &dyn PlainDB<H::Out, T>
fn as_plain_db(&self) -> &dyn PlainDB<H::Out, T>
Perform upcast to PlainDB for anything that derives from PlainDB.
sourcefn as_plain_db_mut(&mut self) -> &mut dyn PlainDB<H::Out, T>
fn as_plain_db_mut(&mut self) -> &mut dyn PlainDB<H::Out, T>
Perform mutable upcast to PlainDB for anything that derives from PlainDB.
sourceimpl<H, KF, T, M> Clone for MemoryDB<H, KF, T, M> where
H: KeyHasher,
KF: KeyFunction<H>,
T: Clone,
M: MemTracker<T> + Copy,
impl<H, KF, T, M> Clone for MemoryDB<H, KF, T, M> where
H: KeyHasher,
KF: KeyFunction<H>,
T: Clone,
M: MemTracker<T> + Copy,
sourceimpl<'a, H, KF, T, M> Default for MemoryDB<H, KF, T, M> where
H: KeyHasher,
T: From<&'a [u8]>,
KF: KeyFunction<H>,
M: MemTracker<T> + Default,
impl<'a, H, KF, T, M> Default for MemoryDB<H, KF, T, M> where
H: KeyHasher,
T: From<&'a [u8]>,
KF: KeyFunction<H>,
M: MemTracker<T> + Default,
sourceimpl<H, KF, T, M> HashDB<H, T> for MemoryDB<H, KF, T, M> where
H: KeyHasher,
T: Default + PartialEq<T> + for<'a> From<&'a [u8]> + Clone + Send + Sync,
KF: Send + Sync + KeyFunction<H>,
M: MemTracker<T> + Send + Sync,
impl<H, KF, T, M> HashDB<H, T> for MemoryDB<H, KF, T, M> where
H: KeyHasher,
T: Default + PartialEq<T> + for<'a> From<&'a [u8]> + Clone + Send + Sync,
KF: Send + Sync + KeyFunction<H>,
M: MemTracker<T> + Send + Sync,
sourcefn get(&self, key: &H::Out, prefix: Prefix<'_>) -> Option<T>
fn get(&self, key: &H::Out, prefix: Prefix<'_>) -> Option<T>
Look up a given hash into the bytes that hash to it, returning None if the hash is not known. Read more
sourcefn contains(&self, key: &H::Out, prefix: Prefix<'_>) -> bool
fn contains(&self, key: &H::Out, prefix: Prefix<'_>) -> bool
Check for the existance of a hash-key.
sourcefn emplace(&mut self, key: H::Out, prefix: Prefix<'_>, value: T)
fn emplace(&mut self, key: H::Out, prefix: Prefix<'_>, value: T)
Like insert()
, except you provide the key and the data is all moved.
sourceimpl<H, KF, T, M> HashDBRef<H, T> for MemoryDB<H, KF, T, M> where
H: KeyHasher,
T: Default + PartialEq<T> + for<'a> From<&'a [u8]> + Clone + Send + Sync,
KF: KeyFunction<H> + Send + Sync,
M: MemTracker<T> + Send + Sync,
impl<H, KF, T, M> HashDBRef<H, T> for MemoryDB<H, KF, T, M> where
H: KeyHasher,
T: Default + PartialEq<T> + for<'a> From<&'a [u8]> + Clone + Send + Sync,
KF: KeyFunction<H> + Send + Sync,
M: MemTracker<T> + Send + Sync,
sourceimpl<H, KF, T, M> MallocSizeOf for MemoryDB<H, KF, T, M> where
H: KeyHasher,
H::Out: MallocSizeOf,
T: MallocSizeOf,
KF: KeyFunction<H>,
KF::Key: MallocSizeOf,
M: MemTracker<T>,
impl<H, KF, T, M> MallocSizeOf for MemoryDB<H, KF, T, M> where
H: KeyHasher,
H::Out: MallocSizeOf,
T: MallocSizeOf,
KF: KeyFunction<H>,
KF::Key: MallocSizeOf,
M: MemTracker<T>,
sourcefn size_of(&self, ops: &mut MallocSizeOfOps) -> usize
fn size_of(&self, ops: &mut MallocSizeOfOps) -> usize
Measure the heap usage of all descendant heap-allocated structures, but
not the space taken up by the value itself.
If T::size_of
is a constant, consider implementing constant_size
as well. Read more
sourcefn constant_size() -> Option<usize>
fn constant_size() -> Option<usize>
Used to optimize MallocSizeOf
implementation for collections
like Vec
and HashMap
to avoid iterating over them unnecessarily.
The Self: Sized
bound is for object safety. Read more
sourceimpl<H, KF, T, M> PartialEq<MemoryDB<H, KF, T, M>> for MemoryDB<H, KF, T, M> where
H: KeyHasher,
KF: KeyFunction<H>,
<KF as KeyFunction<H>>::Key: Eq + MaybeDebug,
T: Eq + MaybeDebug,
M: MemTracker<T> + PartialEq,
impl<H, KF, T, M> PartialEq<MemoryDB<H, KF, T, M>> for MemoryDB<H, KF, T, M> where
H: KeyHasher,
KF: KeyFunction<H>,
<KF as KeyFunction<H>>::Key: Eq + MaybeDebug,
T: Eq + MaybeDebug,
M: MemTracker<T> + PartialEq,
sourceimpl<H, KF, T, M> PlainDB<<H as Hasher>::Out, T> for MemoryDB<H, KF, T, M> where
H: KeyHasher,
T: Default + PartialEq<T> + for<'a> From<&'a [u8]> + Clone + Send + Sync,
KF: Send + Sync + KeyFunction<H>,
KF::Key: Borrow<[u8]> + for<'a> From<&'a [u8]>,
M: MemTracker<T> + Send + Sync,
impl<H, KF, T, M> PlainDB<<H as Hasher>::Out, T> for MemoryDB<H, KF, T, M> where
H: KeyHasher,
T: Default + PartialEq<T> + for<'a> From<&'a [u8]> + Clone + Send + Sync,
KF: Send + Sync + KeyFunction<H>,
KF::Key: Borrow<[u8]> + for<'a> From<&'a [u8]>,
M: MemTracker<T> + Send + Sync,
sourcefn get(&self, key: &H::Out) -> Option<T>
fn get(&self, key: &H::Out) -> Option<T>
Look up a given hash into the bytes that hash to it, returning None if the hash is not known. Read more
sourcefn emplace(&mut self, key: H::Out, value: T)
fn emplace(&mut self, key: H::Out, value: T)
Insert a datum item into the DB. Insertions are counted and the equivalent
number of remove()
s must be performed before the data is considered dead.
The caller should ensure that a key only corresponds to one value. Read more
sourcefn remove(&mut self, key: &H::Out)
fn remove(&mut self, key: &H::Out)
Remove a datum previously inserted. Insertions can be “owed” such that the
same number of insert()
s may happen without the data being eventually
being inserted into the DB. It can be “owed” more than once.
The caller should ensure that a key only corresponds to one value. Read more
sourceimpl<H, KF, T, M> PlainDBRef<<H as Hasher>::Out, T> for MemoryDB<H, KF, T, M> where
H: KeyHasher,
T: Default + PartialEq<T> + for<'a> From<&'a [u8]> + Clone + Send + Sync,
KF: Send + Sync + KeyFunction<H>,
KF::Key: Borrow<[u8]> + for<'a> From<&'a [u8]>,
M: MemTracker<T> + Send + Sync,
impl<H, KF, T, M> PlainDBRef<<H as Hasher>::Out, T> for MemoryDB<H, KF, T, M> where
H: KeyHasher,
T: Default + PartialEq<T> + for<'a> From<&'a [u8]> + Clone + Send + Sync,
KF: Send + Sync + KeyFunction<H>,
KF::Key: Borrow<[u8]> + for<'a> From<&'a [u8]>,
M: MemTracker<T> + Send + Sync,
impl<H, KF, T, M> Eq for MemoryDB<H, KF, T, M> where
H: KeyHasher,
KF: KeyFunction<H>,
<KF as KeyFunction<H>>::Key: Eq + MaybeDebug,
T: Eq + MaybeDebug,
M: MemTracker<T> + Eq,
Auto Trait Implementations
impl<H, KF, T, M> RefUnwindSafe for MemoryDB<H, KF, T, M> where
KF: RefUnwindSafe,
M: RefUnwindSafe,
T: RefUnwindSafe,
<KF as KeyFunction<H>>::Key: RefUnwindSafe,
<H as Hasher>::Out: RefUnwindSafe,
impl<H, KF, T, M> Send for MemoryDB<H, KF, T, M> where
KF: Send,
M: Send,
T: Send,
impl<H, KF, T, M> Sync for MemoryDB<H, KF, T, M> where
KF: Sync,
M: Sync,
T: Sync,
impl<H, KF, T, M> Unpin for MemoryDB<H, KF, T, M> where
KF: Unpin,
M: Unpin,
T: Unpin,
<KF as KeyFunction<H>>::Key: Unpin,
<H as Hasher>::Out: Unpin,
impl<H, KF, T, M> UnwindSafe for MemoryDB<H, KF, T, M> where
KF: UnwindSafe,
M: UnwindSafe,
T: UnwindSafe,
<KF as KeyFunction<H>>::Key: UnwindSafe,
<H as Hasher>::Out: UnwindSafe,
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcepub fn borrow_mut(&mut self) -> &mut T
pub fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> MallocSizeOfExt for T where
T: MallocSizeOf,
impl<T> MallocSizeOfExt for T where
T: MallocSizeOf,
sourcefn malloc_size_of(&self) -> usize
fn malloc_size_of(&self) -> usize
Method to launch a heapsize measurement with a fresh state. Read more
sourceimpl<T> ToOwned for T where
T: Clone,
impl<T> ToOwned for T where
T: Clone,
type Owned = T
type Owned = T
The resulting type after obtaining ownership.
sourcepub fn to_owned(&self) -> T
pub fn to_owned(&self) -> T
Creates owned data from borrowed data, usually by cloning. Read more
sourcepub fn clone_into(&self, target: &mut T)
pub fn clone_into(&self, target: &mut T)
toowned_clone_into
)Uses borrowed data to replace owned data, usually by cloning. Read more