Enum DbImpl 

pub enum DbImpl {
    ManyCarWithGarbageCollectableParityDb(Arc<ManyCar<Arc<GarbageCollectableParityDb>>>),
    ManyCarWithMemoryDB(Arc<ManyCar<MemoryDB>>),
    ManyCarParityDb(Arc<ManyCar<ParityDb>>),
    Memory(Arc<MemoryDB>),
    ReadOpsTrackingManyCarParityDb(Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>),
}

Variants

ManyCarWithGarbageCollectableParityDb(Arc<ManyCar<Arc<GarbageCollectableParityDb>>>)

ManyCarWithMemoryDB(Arc<ManyCar<MemoryDB>>)

ManyCarParityDb(Arc<ManyCar<ParityDb>>)

Memory(Arc<MemoryDB>)

ReadOpsTrackingManyCarParityDb(Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>)

Trait Implementations

impl BitswapStoreRead for DbImpl

where Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>: BitswapStoreRead, Arc<ManyCar<Arc<GarbageCollectableParityDb>>>: MatchBitswapStoreRead<Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>>, Arc<ManyCar<MemoryDB>>: MatchBitswapStoreRead<Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>>, Arc<ManyCar<ParityDb>>: MatchBitswapStoreRead<Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>>, Arc<MemoryDB>: MatchBitswapStoreRead<Arc<ReadOpsTrackingStore<ManyCar<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 DbImpl

where Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>: BitswapStoreReadWrite, Arc<ManyCar<Arc<GarbageCollectableParityDb>>>: MatchBitswapStoreReadWrite<Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>>, Arc<ManyCar<MemoryDB>>: MatchBitswapStoreReadWrite<Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>>, Arc<ManyCar<ParityDb>>: MatchBitswapStoreReadWrite<Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>>, Arc<MemoryDB>: MatchBitswapStoreReadWrite<Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>>,

type Hashes = <Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>> as BitswapStoreReadWrite>::Hashes

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 DbImpl

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) -> Result<bool>

Checks if the blockstore has the specified block.

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

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<()>

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<()>

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

Bulk-put pre-keyed blocks into the blockstore.

impl BlockstoreWriteOpsSubscribable for DbImpl

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

fn unsubscribe_write_ops(&self)

impl EnumExtensions for DbImpl

fn try_into_var<Var>(self) -> Result<Var, Self>

where Var: FromEnum<Self>,

Attempts to “cast” this enum into one of its variants.

fn try_ref_var<Var>(&self) -> Option<&Var>

where Var: FromEnumRef<Self>,

Attempts to get a reference to the variant Var, if self matches the variant.

fn try_mut_var<Var>(&mut self) -> Option<&mut Var>

where Var: FromEnumMut<Self>,

Attempts to get a mutable reference to the variant Var, if self matches the variant.

fn is_var<Var>(&self) -> bool

where Var: FromEnumRef<Self>,

Checks if self matches the variant Var.

impl EthMappingsStore for DbImpl

where Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>: EthMappingsStore, Arc<ManyCar<Arc<GarbageCollectableParityDb>>>: MatchEthMappingsStore<Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>>, Arc<ManyCar<MemoryDB>>: MatchEthMappingsStore<Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>>, Arc<ManyCar<ParityDb>>: MatchEthMappingsStore<Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>>, Arc<MemoryDB>: MatchEthMappingsStore<Arc<ReadOpsTrackingStore<ManyCar<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.

fn tipset_key_by_epoch(&self, epoch: ChainEpoch) -> Result<Option<TipsetKey>>

Reads the tipset key for a given epoch(height) from the store.

fn delete_tipset_key_at_epoch(&self, epoch: ChainEpoch) -> Result<()>

Deletes the tipset key at a given epoch(height) from the store.

fn set_tipset_key_at_epoch_raw( &self, epoch: ChainEpoch, tsk: &TipsetKey, ) -> Result<()>

Writes the tipset key for a given epoch(height) to the store.

fn set_tipset_key_at_epoch(&self, ts: &Tipset) -> Result<()>

Writes the tipset key for a given epoch(height) to the store.

impl From<Arc<ManyCar<Arc<GarbageCollectableParityDb>>>> for DbImpl

fn from(_value: Arc<ManyCar<Arc<GarbageCollectableParityDb>>>) -> Self

Converts to this type from the input type.

impl From<Arc<ManyCar<ParityDb>>> for DbImpl

fn from(_value: Arc<ManyCar<ParityDb>>) -> Self

Converts to this type from the input type.

impl From<Arc<ManyCar>> for DbImpl

fn from(_value: Arc<ManyCar<MemoryDB>>) -> Self

Converts to this type from the input type.

impl From<Arc<MemoryDB>> for DbImpl

fn from(_value: Arc<MemoryDB>) -> Self

Converts to this type from the input type.

impl From<Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>> for DbImpl

fn from(_value: Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>) -> Self

Converts to this type from the input type.

impl FromEnum<DbImpl> for Arc<ManyCar<Arc<GarbageCollectableParityDb>>>

fn from_enum(_value: DbImpl) -> Result<Self, DbImpl>

The inverse of EnumExtensions::try_into_var, see that method’s documentation for more.

impl FromEnum<DbImpl> for Arc<ManyCar<MemoryDB>>

fn from_enum(_value: DbImpl) -> Result<Self, DbImpl>

The inverse of EnumExtensions::try_into_var, see that method’s documentation for more.

impl FromEnum<DbImpl> for Arc<ManyCar<ParityDb>>

fn from_enum(_value: DbImpl) -> Result<Self, DbImpl>

The inverse of EnumExtensions::try_into_var, see that method’s documentation for more.

impl FromEnum<DbImpl> for Arc<MemoryDB>

fn from_enum(_value: DbImpl) -> Result<Self, DbImpl>

The inverse of EnumExtensions::try_into_var, see that method’s documentation for more.

impl FromEnum<DbImpl> for Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>

fn from_enum(_value: DbImpl) -> Result<Self, DbImpl>

The inverse of EnumExtensions::try_into_var, see that method’s documentation for more.

impl<'_r1> FromEnumMut<DbImpl> for Arc<ManyCar<Arc<GarbageCollectableParityDb>>>

fn from_enum_mut<'__ref>(_value: &'__ref mut DbImpl) -> Option<&'__ref mut Self>

The inverse of EnumExtensions::try_mut_var, see that method’s documentation for more.

impl<'_r1> FromEnumMut<DbImpl> for Arc<ManyCar<MemoryDB>>

fn from_enum_mut<'__ref>(_value: &'__ref mut DbImpl) -> Option<&'__ref mut Self>

The inverse of EnumExtensions::try_mut_var, see that method’s documentation for more.

impl<'_r1> FromEnumMut<DbImpl> for Arc<ManyCar<ParityDb>>

fn from_enum_mut<'__ref>(_value: &'__ref mut DbImpl) -> Option<&'__ref mut Self>

The inverse of EnumExtensions::try_mut_var, see that method’s documentation for more.

impl<'_r1> FromEnumMut<DbImpl> for Arc<MemoryDB>

fn from_enum_mut<'__ref>(_value: &'__ref mut DbImpl) -> Option<&'__ref mut Self>

The inverse of EnumExtensions::try_mut_var, see that method’s documentation for more.

impl<'_r1> FromEnumMut<DbImpl> for Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>

fn from_enum_mut<'__ref>(_value: &'__ref mut DbImpl) -> Option<&'__ref mut Self>

The inverse of EnumExtensions::try_mut_var, see that method’s documentation for more.

impl<'_r1> FromEnumRef<DbImpl> for Arc<ManyCar<Arc<GarbageCollectableParityDb>>>

fn from_enum_ref<'__ref>(_value: &'__ref DbImpl) -> Option<&'__ref Self>

The inverse of EnumExtensions::try_ref_var, see that method’s documentation for more.

impl<'_r1> FromEnumRef<DbImpl> for Arc<ManyCar<MemoryDB>>

fn from_enum_ref<'__ref>(_value: &'__ref DbImpl) -> Option<&'__ref Self>

The inverse of EnumExtensions::try_ref_var, see that method’s documentation for more.

impl<'_r1> FromEnumRef<DbImpl> for Arc<ManyCar<ParityDb>>

fn from_enum_ref<'__ref>(_value: &'__ref DbImpl) -> Option<&'__ref Self>

The inverse of EnumExtensions::try_ref_var, see that method’s documentation for more.

impl<'_r1> FromEnumRef<DbImpl> for Arc<MemoryDB>

fn from_enum_ref<'__ref>(_value: &'__ref DbImpl) -> Option<&'__ref Self>

The inverse of EnumExtensions::try_ref_var, see that method’s documentation for more.

impl<'_r1> FromEnumRef<DbImpl> for Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>

fn from_enum_ref<'__ref>(_value: &'__ref DbImpl) -> Option<&'__ref Self>

The inverse of EnumExtensions::try_ref_var, see that method’s documentation for more.

impl GarbageCollectableDb for DbImpl

fn reset_gc_columns(&self) -> Result<()>

impl HeaviestTipsetKeyProvider for DbImpl

where Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>: HeaviestTipsetKeyProvider, Arc<ManyCar<Arc<GarbageCollectableParityDb>>>: MatchHeaviestTipsetKeyProvider<Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>>, Arc<ManyCar<MemoryDB>>: MatchHeaviestTipsetKeyProvider<Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>>, Arc<ManyCar<ParityDb>>: MatchHeaviestTipsetKeyProvider<Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>>, Arc<MemoryDB>: MatchHeaviestTipsetKeyProvider<Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>>,

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

Returns the currently tracked heaviest tipset.

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

Sets heaviest tipset.

impl ReloadableManyCar for DbImpl

fn clear_and_reload_cars( &self, files: impl Iterator<Item = PathBuf>, ) -> Result<()>

fn heaviest_car_tipset(&self) -> Result<Tipset>

impl SettingsStore for DbImpl

where Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>: SettingsStore, Arc<ManyCar<Arc<GarbageCollectableParityDb>>>: MatchSettingsStore<Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>>, Arc<ManyCar<MemoryDB>>: MatchSettingsStore<Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>>, Arc<ManyCar<ParityDb>>: MatchSettingsStore<Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>>, Arc<MemoryDB>: MatchSettingsStore<Arc<ReadOpsTrackingStore<ManyCar<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.

impl ShallowClone for DbImpl

fn shallow_clone(&self) -> Self

Performs a lightweight clone.

impl<'_r1> TryFrom<&'_r1 DbImpl> for &'_r1 Arc<ManyCar<Arc<GarbageCollectableParityDb>>>

type Error = ()

The type returned in the event of a conversion error.

fn try_from(_value: &'_r1 DbImpl) -> Result<Self, Self::Error>

Performs the conversion.

impl<'_r1> TryFrom<&'_r1 DbImpl> for &'_r1 Arc<ManyCar<MemoryDB>>

type Error = ()

The type returned in the event of a conversion error.

fn try_from(_value: &'_r1 DbImpl) -> Result<Self, Self::Error>

Performs the conversion.

impl<'_r1> TryFrom<&'_r1 DbImpl> for &'_r1 Arc<ManyCar<ParityDb>>

type Error = ()

The type returned in the event of a conversion error.

fn try_from(_value: &'_r1 DbImpl) -> Result<Self, Self::Error>

Performs the conversion.

impl<'_r1> TryFrom<&'_r1 DbImpl> for &'_r1 Arc<MemoryDB>

type Error = ()

The type returned in the event of a conversion error.

fn try_from(_value: &'_r1 DbImpl) -> Result<Self, Self::Error>

Performs the conversion.

impl<'_r1> TryFrom<&'_r1 DbImpl> for &'_r1 Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>

type Error = ()

The type returned in the event of a conversion error.

fn try_from(_value: &'_r1 DbImpl) -> Result<Self, Self::Error>

Performs the conversion.

impl<'_r1> TryFrom<&'_r1 mut DbImpl> for &'_r1 mut Arc<ManyCar<Arc<GarbageCollectableParityDb>>>

type Error = ()

The type returned in the event of a conversion error.

fn try_from(_value: &'_r1 mut DbImpl) -> Result<Self, Self::Error>

Performs the conversion.

impl<'_r1> TryFrom<&'_r1 mut DbImpl> for &'_r1 mut Arc<ManyCar<MemoryDB>>

type Error = ()

The type returned in the event of a conversion error.

fn try_from(_value: &'_r1 mut DbImpl) -> Result<Self, Self::Error>

Performs the conversion.

impl<'_r1> TryFrom<&'_r1 mut DbImpl> for &'_r1 mut Arc<ManyCar<ParityDb>>

type Error = ()

The type returned in the event of a conversion error.

fn try_from(_value: &'_r1 mut DbImpl) -> Result<Self, Self::Error>

Performs the conversion.

impl<'_r1> TryFrom<&'_r1 mut DbImpl> for &'_r1 mut Arc<MemoryDB>

type Error = ()

The type returned in the event of a conversion error.

fn try_from(_value: &'_r1 mut DbImpl) -> Result<Self, Self::Error>

Performs the conversion.

impl<'_r1> TryFrom<&'_r1 mut DbImpl> for &'_r1 mut Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>

type Error = ()

The type returned in the event of a conversion error.

fn try_from(_value: &'_r1 mut DbImpl) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<DbImpl> for Arc<ManyCar<Arc<GarbageCollectableParityDb>>>

type Error = DbImpl

The type returned in the event of a conversion error.

fn try_from(_value: DbImpl) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<DbImpl> for Arc<ManyCar<MemoryDB>>

type Error = DbImpl

The type returned in the event of a conversion error.

fn try_from(_value: DbImpl) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<DbImpl> for Arc<ManyCar<ParityDb>>

type Error = DbImpl

The type returned in the event of a conversion error.

fn try_from(_value: DbImpl) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<DbImpl> for Arc<MemoryDB>

type Error = DbImpl

The type returned in the event of a conversion error.

fn try_from(_value: DbImpl) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<DbImpl> for Arc<ReadOpsTrackingStore<ManyCar<ParityDb>>>

type Error = DbImpl

The type returned in the event of a conversion error.

fn try_from(_value: DbImpl) -> Result<Self, Self::Error>

Performs the conversion.