Struct ParityDb 

pub struct ParityDb {
    pub db: Db,
    statistics_enabled: bool,
    disable_persistent_fallback: bool,
    write_ops_broadcast_tx: RwLock<Option<Sender<(Cid, Vec<u8>)>>>,
}

Fields

db: Db

statistics_enabled: bool

disable_persistent_fallback: bool

write_ops_broadcast_tx: RwLock<Option<Sender<(Cid, Vec<u8>)>>>

Implementations

impl ParityDb

pub fn to_options(path: PathBuf, config: &ParityDbConfig) -> Options

pub fn open(path: impl Into<PathBuf>, config: &ParityDbConfig) -> Result<Self>

fn choose_column(cid: &Cid) -> DbColumn

Returns an appropriate column variant based on the information in the Cid.

fn read_from_column<K>( &self, key: K, column: DbColumn, ) -> Result<Option<Vec<u8>>>

where K: AsRef<[u8]>,

fn write_to_column<K, V>( &self, key: K, value: V, column: DbColumn, ) -> Result<()>

where K: AsRef<[u8]>, V: AsRef<[u8]>,

impl ParityDb

pub fn dereference_operation(key: &Cid) -> (u8, Operation<Vec<u8>, Vec<u8>>)

Removes a record.

Arguments

• key - record identifier

pub fn set_operation( column: u8, key: Vec<u8>, value: Vec<u8>, ) -> (u8, Operation<Vec<u8>, Vec<u8>>)

Updates/inserts a record.

Arguments

• column - column identifier
• key - record identifier
• value - record contents

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

Trait Implementations

impl BitswapStoreRead for ParityDb

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 ParityDb

type Hashes = MultihashCode

The hashes parameters.

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

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

impl Blockstore for ParityDb

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 put_many_keyed<D, I>(&self, blocks: I) -> Result<()>

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

Bulk-put pre-keyed blocks into the blockstore.

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.

impl BlockstoreWriteOpsSubscribable for ParityDb

fn subscribe_write_ops(&self) -> Receiver<(Cid, Vec<u8>)>

fn unsubscribe_write_ops(&self)

impl DBStatistics for ParityDb

fn get_statistics(&self) -> Option<String>

impl EthMappingsStore for ParityDb

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 HeaviestTipsetKeyProvider for ParityDb

fn heaviest_tipset_key(&self) -> Result<TipsetKey>

Returns the currently tracked heaviest tipset.

fn set_heaviest_tipset_key(&self, tsk: &TipsetKey) -> Result<()>

Sets heaviest tipset.

impl IndicesStore for ParityDb

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

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

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

impl PersistentStore for ParityDb

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

Puts a keyed block with pre-computed CID into the database.

impl SettingsStore for ParityDb

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.