Struct forest_filecoin::db::memory::MemoryDB

pub struct MemoryDB {
    blockchain_db: RwLock<HashMap<Vec<u8>, Vec<u8>>>,
    settings_db: RwLock<HashMap<String, Vec<u8>>>,
    eth_mappings_db: RwLock<HashMap<EthHash, Vec<u8>>>,
}

Fields

blockchain_db: RwLock<HashMap<Vec<u8>, Vec<u8>>>

settings_db: RwLock<HashMap<String, Vec<u8>>>

eth_mappings_db: RwLock<HashMap<EthHash, Vec<u8>>>

Trait Implementations

impl BitswapStoreRead for MemoryDB

fn contains(&self, cid: &Cid) -> Result<bool>

A have query needs to know if the block store contains the block.

fn get(&self, cid: &Cid) -> Result<Option<Vec<u8>>>

A block query needs to retrieve the block from the store.

impl BitswapStoreReadWrite for MemoryDB

type Params = DefaultParams

The store parameters.

fn insert(&self, block: &Block<Self::Params>) -> Result<()>

A block response needs to insert the block into the store.

impl Blockstore for MemoryDB

fn get(&self, k: &Cid) -> Result<Option<Vec<u8>>>

Gets the block from the blockstore.

fn put_keyed(&self, k: &Cid, block: &[u8]) -> Result<()>

Put a block with a pre-computed cid.

fn has(&self, k: &Cid<64>) -> Result<bool, Error>

Checks if the blockstore has the specified block.

fn put<D>(&self, mh_code: Code, block: &Block<D>) -> Result<Cid<64>, Error>

where Self: Sized, D: AsRef<[u8]>,

Puts the block into the blockstore, computing the hash with the specified multicodec.

fn put_many<D, I>(&self, blocks: I) -> Result<(), Error>

where Self: Sized, D: AsRef<[u8]>, I: IntoIterator<Item = (Code, Block<D>)>,

Bulk put blocks into the blockstore.

fn put_many_keyed<D, I>(&self, blocks: I) -> Result<(), Error>

where Self: Sized, D: AsRef<[u8]>, I: IntoIterator<Item = (Cid<64>, D)>,

Bulk-put pre-keyed blocks into the blockstore.

impl Debug for MemoryDB

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

Formats the value using the given formatter.

impl Default for MemoryDB

fn default() -> MemoryDB

Returns the “default value” for a type.

impl EthMappingsStore for MemoryDB

fn read_bin(&self, key: &EthHash) -> Result<Option<Vec<u8>>>

Reads binary field from the EthMappings store. This should be used for non-serializable data. For serializable data, use EthMappingsStoreExt::read_obj.

fn write_bin(&self, key: &EthHash, value: &[u8]) -> Result<()>

Writes binary field to the EthMappings store. This should be used for non-serializable data. For serializable data, use EthMappingsStoreExt::write_obj.

fn exists(&self, key: &EthHash) -> Result<bool>

Returns Ok(true) if key exists in store.

fn get_message_cids(&self) -> Result<Vec<(Cid, u64)>>

Returns all message CIDs with their timestamp.

fn delete(&self, keys: Vec<EthHash>) -> Result<()>

Deletes keys if keys exist in store.

impl GarbageCollectable<CidHashSet> for MemoryDB

fn get_keys(&self) -> Result<CidHashSet>

Gets all the keys currently in the database.

fn remove_keys(&self, keys: CidHashSet) -> Result<u32>

Removes all the keys marked for deletion.

impl SettingsStore for MemoryDB

fn read_bin(&self, key: &str) -> Result<Option<Vec<u8>>>

Reads binary field from the Settings store. This should be used for non-serializable data. For serializable data, use SettingsStoreExt::read_obj.

fn write_bin(&self, key: &str, value: &[u8]) -> Result<()>

Writes binary field to the Settings store. This should be used for non-serializable data. For serializable data, use SettingsStoreExt::write_obj.

fn exists(&self, key: &str) -> Result<bool>

Returns Ok(true) if key exists in store.

fn setting_keys(&self) -> Result<Vec<String>>

Returns all setting keys.