Struct DatabaseProvider
pub struct DatabaseProvider<TX, N>where
N: NodeTypes,{ /* private fields */ }
Expand description
A provider struct that fetches data from the database.
Wrapper around [DbTx
] and [DbTxMut
]. Example: HeaderProvider
BlockHashReader
Implementations§
§impl<TX, N> DatabaseProvider<TX, N>where
N: NodeTypes,
impl<TX, N> DatabaseProvider<TX, N>where
N: NodeTypes,
pub const fn prune_modes_ref(&self) -> &PruneModes
pub const fn prune_modes_ref(&self) -> &PruneModes
Returns reference to prune modes.
§impl<TX, N> DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypes,
impl<TX, N> DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypes,
pub fn latest<'a>(&'a self) -> Box<dyn StateProvider + 'a>
pub fn latest<'a>(&'a self) -> Box<dyn StateProvider + 'a>
State provider for latest state
pub fn history_by_block_hash<'a>(
&'a self,
block_hash: FixedBytes<32>,
) -> Result<Box<dyn StateProvider + 'a>, ProviderError>
pub fn history_by_block_hash<'a>( &'a self, block_hash: FixedBytes<32>, ) -> Result<Box<dyn StateProvider + 'a>, ProviderError>
Storage provider for state at that given block hash
pub fn set_prune_modes(&mut self, prune_modes: PruneModes)
Available on crate feature test-utils
only.
pub fn set_prune_modes(&mut self, prune_modes: PruneModes)
test-utils
only.Sets the prune modes for provider.
§impl<TX, N> DatabaseProvider<TX, N>where
TX: DbTxMut,
N: NodeTypes,
impl<TX, N> DatabaseProvider<TX, N>where
TX: DbTxMut,
N: NodeTypes,
pub const fn new_rw(
tx: TX,
chain_spec: Arc<<N as NodeTypes>::ChainSpec>,
static_file_provider: StaticFileProvider<<N as NodeTypes>::Primitives>,
prune_modes: PruneModes,
storage: Arc<<N as NodeTypes>::Storage>,
) -> DatabaseProvider<TX, N>
pub const fn new_rw( tx: TX, chain_spec: Arc<<N as NodeTypes>::ChainSpec>, static_file_provider: StaticFileProvider<<N as NodeTypes>::Primitives>, prune_modes: PruneModes, storage: Arc<<N as NodeTypes>::Storage>, ) -> DatabaseProvider<TX, N>
Creates a provider with an inner read-write transaction.
§impl<TX, N> DatabaseProvider<TX, N>where
TX: DbTx + DbTxMut + 'static,
N: NodeTypesForProvider,
impl<TX, N> DatabaseProvider<TX, N>where
TX: DbTx + DbTxMut + 'static,
N: NodeTypesForProvider,
pub fn unwind_trie_state_range(
&self,
range: RangeInclusive<u64>,
) -> Result<(), ProviderError>
pub fn unwind_trie_state_range( &self, range: RangeInclusive<u64>, ) -> Result<(), ProviderError>
Unwinds trie state for the given range.
This includes calculating the resulted state root and comparing it with the parent block state root.
§impl<Tx, N> DatabaseProvider<Tx, N>where
Tx: DbTx + DbTxMut + 'static,
N: NodeTypesForProvider,
<N as NodeTypes>::Primitives: NodePrimitives<BlockHeader = Header>,
impl<Tx, N> DatabaseProvider<Tx, N>where
Tx: DbTx + DbTxMut + 'static,
N: NodeTypesForProvider,
<N as NodeTypes>::Primitives: NodePrimitives<BlockHeader = Header>,
pub fn insert_historical_block(
&self,
block: RecoveredBlock<<DatabaseProvider<Tx, N> as BlockWriter>::Block>,
) -> Result<StoredBlockBodyIndices, ProviderError>
pub fn insert_historical_block( &self, block: RecoveredBlock<<DatabaseProvider<Tx, N> as BlockWriter>::Block>, ) -> Result<StoredBlockBodyIndices, ProviderError>
Inserts an historical block. Used for setting up test environments
§impl<TX, N> DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypesForProvider,
impl<TX, N> DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypesForProvider,
pub const fn new(
tx: TX,
chain_spec: Arc<<N as NodeTypes>::ChainSpec>,
static_file_provider: StaticFileProvider<<N as NodeTypes>::Primitives>,
prune_modes: PruneModes,
storage: Arc<<N as NodeTypes>::Storage>,
) -> DatabaseProvider<TX, N>
pub const fn new( tx: TX, chain_spec: Arc<<N as NodeTypes>::ChainSpec>, static_file_provider: StaticFileProvider<<N as NodeTypes>::Primitives>, prune_modes: PruneModes, storage: Arc<<N as NodeTypes>::Storage>, ) -> DatabaseProvider<TX, N>
Creates a provider with an inner read-only transaction.
pub fn into_tx(self) -> TX
pub fn into_tx(self) -> TX
Consume DbTx
or DbTxMut
.
pub fn chain_spec(&self) -> &<N as NodeTypes>::ChainSpec
pub fn chain_spec(&self) -> &<N as NodeTypes>::ChainSpec
Returns a reference to the chain specification.
§impl<TX, N> DatabaseProvider<TX, N>where
TX: DbTxMut + DbTx + 'static,
N: NodeTypes,
impl<TX, N> DatabaseProvider<TX, N>where
TX: DbTxMut + DbTx + 'static,
N: NodeTypes,
pub fn commit(self) -> Result<bool, ProviderError>
pub fn commit(self) -> Result<bool, ProviderError>
Commit database transaction.
Trait Implementations§
§impl<TX, N> AccountExtReader for DatabaseProvider<TX, N>where
TX: DbTx,
N: NodeTypes,
impl<TX, N> AccountExtReader for DatabaseProvider<TX, N>where
TX: DbTx,
N: NodeTypes,
§fn changed_accounts_with_range(
&self,
range: impl RangeBounds<u64>,
) -> Result<BTreeSet<Address>, ProviderError>
fn changed_accounts_with_range( &self, range: impl RangeBounds<u64>, ) -> Result<BTreeSet<Address>, ProviderError>
§fn basic_accounts(
&self,
iter: impl IntoIterator<Item = Address>,
) -> Result<Vec<(Address, Option<Account>)>, ProviderError>
fn basic_accounts( &self, iter: impl IntoIterator<Item = Address>, ) -> Result<Vec<(Address, Option<Account>)>, ProviderError>
AccountReader::basic_account
repeatedly. Read more§fn changed_accounts_and_blocks_with_range(
&self,
range: RangeInclusive<u64>,
) -> Result<BTreeMap<Address, Vec<u64>>, ProviderError>
fn changed_accounts_and_blocks_with_range( &self, range: RangeInclusive<u64>, ) -> Result<BTreeMap<Address, Vec<u64>>, ProviderError>
§impl<TX, N> AccountReader for DatabaseProvider<TX, N>where
TX: DbTx,
N: NodeTypes,
impl<TX, N> AccountReader for DatabaseProvider<TX, N>where
TX: DbTx,
N: NodeTypes,
§fn basic_account(
&self,
address: &Address,
) -> Result<Option<Account>, ProviderError>
fn basic_account( &self, address: &Address, ) -> Result<Option<Account>, ProviderError>
§impl<DB, N> AsRef<DatabaseProvider<<DB as Database>::TXMut, N>> for DatabaseProviderRW<DB, N>where
DB: Database,
N: NodeTypes,
impl<DB, N> AsRef<DatabaseProvider<<DB as Database>::TXMut, N>> for DatabaseProviderRW<DB, N>where
DB: Database,
N: NodeTypes,
§fn as_ref(&self) -> &DatabaseProvider<<DB as Database>::TXMut, N>
fn as_ref(&self) -> &DatabaseProvider<<DB as Database>::TXMut, N>
§impl<TX, N> AsRef<DatabaseProvider<TX, N>> for DatabaseProvider<TX, N>where
N: NodeTypes,
impl<TX, N> AsRef<DatabaseProvider<TX, N>> for DatabaseProvider<TX, N>where
N: NodeTypes,
§fn as_ref(&self) -> &DatabaseProvider<TX, N>
fn as_ref(&self) -> &DatabaseProvider<TX, N>
§impl<TX, N> BlockBodyIndicesProvider for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypesForProvider,
impl<TX, N> BlockBodyIndicesProvider for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypesForProvider,
§fn block_body_indices(
&self,
num: u64,
) -> Result<Option<StoredBlockBodyIndices>, ProviderError>
fn block_body_indices( &self, num: u64, ) -> Result<Option<StoredBlockBodyIndices>, ProviderError>
§fn block_body_indices_range(
&self,
range: RangeInclusive<u64>,
) -> Result<Vec<StoredBlockBodyIndices>, ProviderError>
fn block_body_indices_range( &self, range: RangeInclusive<u64>, ) -> Result<Vec<StoredBlockBodyIndices>, ProviderError>
§impl<TX, N> BlockExecutionWriter for DatabaseProvider<TX, N>where
TX: DbTxMut + DbTx + 'static,
N: NodeTypesForProvider + 'static,
impl<TX, N> BlockExecutionWriter for DatabaseProvider<TX, N>where
TX: DbTxMut + DbTx + 'static,
N: NodeTypesForProvider + 'static,
§fn take_block_and_execution_above(
&self,
block: u64,
remove_from: StorageLocation,
) -> Result<Chain<<DatabaseProvider<TX, N> as NodePrimitivesProvider>::Primitives>, ProviderError>
fn take_block_and_execution_above( &self, block: u64, remove_from: StorageLocation, ) -> Result<Chain<<DatabaseProvider<TX, N> as NodePrimitivesProvider>::Primitives>, ProviderError>
§fn remove_block_and_execution_above(
&self,
block: u64,
remove_from: StorageLocation,
) -> Result<(), ProviderError>
fn remove_block_and_execution_above( &self, block: u64, remove_from: StorageLocation, ) -> Result<(), ProviderError>
§impl<TX, N> BlockHashReader for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypes,
impl<TX, N> BlockHashReader for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypes,
§fn block_hash(
&self,
number: u64,
) -> Result<Option<FixedBytes<32>>, ProviderError>
fn block_hash( &self, number: u64, ) -> Result<Option<FixedBytes<32>>, ProviderError>
None
if no block with this number
exists.§fn canonical_hashes_range(
&self,
start: u64,
end: u64,
) -> Result<Vec<FixedBytes<32>>, ProviderError>
fn canonical_hashes_range( &self, start: u64, end: u64, ) -> Result<Vec<FixedBytes<32>>, ProviderError>
§fn convert_block_hash(
&self,
hash_or_number: HashOrNumber,
) -> Result<Option<FixedBytes<32>>, ProviderError>
fn convert_block_hash( &self, hash_or_number: HashOrNumber, ) -> Result<Option<FixedBytes<32>>, ProviderError>
None
if no block with this number
exists.§impl<TX, N> BlockNumReader for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypes,
impl<TX, N> BlockNumReader for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypes,
§fn chain_info(&self) -> Result<ChainInfo, ProviderError>
fn chain_info(&self) -> Result<ChainInfo, ProviderError>
§fn best_block_number(&self) -> Result<u64, ProviderError>
fn best_block_number(&self) -> Result<u64, ProviderError>
§fn last_block_number(&self) -> Result<u64, ProviderError>
fn last_block_number(&self) -> Result<u64, ProviderError>
§fn block_number(
&self,
hash: FixedBytes<32>,
) -> Result<Option<u64>, ProviderError>
fn block_number( &self, hash: FixedBytes<32>, ) -> Result<Option<u64>, ProviderError>
BlockNumber
for the given hash. Returns None
if no block with this hash exists.§fn convert_hash_or_number(
&self,
id: HashOrNumber,
) -> Result<Option<u64>, ProviderError>
fn convert_hash_or_number( &self, id: HashOrNumber, ) -> Result<Option<u64>, ProviderError>
BlockHashOrNumber
. Returns None
if no block with
this hash exists. If the BlockHashOrNumber
is a Number
, it is returned as is.§fn convert_number(
&self,
id: HashOrNumber,
) -> Result<Option<FixedBytes<32>>, ProviderError>
fn convert_number( &self, id: HashOrNumber, ) -> Result<Option<FixedBytes<32>>, ProviderError>
BlockHashOrNumber
. Returns None
if no block with this
number exists. If the BlockHashOrNumber
is a Hash
, it is returned as is.§impl<TX, N> BlockReader for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypesForProvider,
impl<TX, N> BlockReader for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypesForProvider,
§fn block(
&self,
id: HashOrNumber,
) -> Result<Option<<DatabaseProvider<TX, N> as BlockReader>::Block>, ProviderError>
fn block( &self, id: HashOrNumber, ) -> Result<Option<<DatabaseProvider<TX, N> as BlockReader>::Block>, ProviderError>
Returns the block with matching number from database.
If the header for this block is not found, this returns None
.
If the header is found, but the transactions either do not exist, or are not indexed, this
will return None.
§fn block_with_senders(
&self,
id: HashOrNumber,
transaction_kind: TransactionVariant,
) -> Result<Option<RecoveredBlock<<DatabaseProvider<TX, N> as BlockReader>::Block>>, ProviderError>
fn block_with_senders( &self, id: HashOrNumber, transaction_kind: TransactionVariant, ) -> Result<Option<RecoveredBlock<<DatabaseProvider<TX, N> as BlockReader>::Block>>, ProviderError>
Returns the block with senders with matching number or hash from database.
NOTE: The transactions have invalid hashes, since they would need to be calculated on the spot, and we want fast querying.
If the header for this block is not found, this returns None
.
If the header is found, but the transactions either do not exist, or are not indexed, this
will return None.
§type Block = <<N as NodeTypes>::Primitives as NodePrimitives>::Block
type Block = <<N as NodeTypes>::Primitives as NodePrimitives>::Block
§fn find_block_by_hash(
&self,
hash: FixedBytes<32>,
source: BlockSource,
) -> Result<Option<<DatabaseProvider<TX, N> as BlockReader>::Block>, ProviderError>
fn find_block_by_hash( &self, hash: FixedBytes<32>, source: BlockSource, ) -> Result<Option<<DatabaseProvider<TX, N> as BlockReader>::Block>, ProviderError>
§fn pending_block(
&self,
) -> Result<Option<SealedBlock<<DatabaseProvider<TX, N> as BlockReader>::Block>>, ProviderError>
fn pending_block( &self, ) -> Result<Option<SealedBlock<<DatabaseProvider<TX, N> as BlockReader>::Block>>, ProviderError>
§fn pending_block_with_senders(
&self,
) -> Result<Option<RecoveredBlock<<DatabaseProvider<TX, N> as BlockReader>::Block>>, ProviderError>
fn pending_block_with_senders( &self, ) -> Result<Option<RecoveredBlock<<DatabaseProvider<TX, N> as BlockReader>::Block>>, ProviderError>
§fn pending_block_and_receipts(
&self,
) -> Result<Option<(SealedBlock<<DatabaseProvider<TX, N> as BlockReader>::Block>, Vec<<DatabaseProvider<TX, N> as ReceiptProvider>::Receipt>)>, ProviderError>
fn pending_block_and_receipts( &self, ) -> Result<Option<(SealedBlock<<DatabaseProvider<TX, N> as BlockReader>::Block>, Vec<<DatabaseProvider<TX, N> as ReceiptProvider>::Receipt>)>, ProviderError>
§fn sealed_block_with_senders(
&self,
id: HashOrNumber,
transaction_kind: TransactionVariant,
) -> Result<Option<RecoveredBlock<<DatabaseProvider<TX, N> as BlockReader>::Block>>, ProviderError>
fn sealed_block_with_senders( &self, id: HashOrNumber, transaction_kind: TransactionVariant, ) -> Result<Option<RecoveredBlock<<DatabaseProvider<TX, N> as BlockReader>::Block>>, ProviderError>
§fn block_range(
&self,
range: RangeInclusive<u64>,
) -> Result<Vec<<DatabaseProvider<TX, N> as BlockReader>::Block>, ProviderError>
fn block_range( &self, range: RangeInclusive<u64>, ) -> Result<Vec<<DatabaseProvider<TX, N> as BlockReader>::Block>, ProviderError>
§fn block_with_senders_range(
&self,
range: RangeInclusive<u64>,
) -> Result<Vec<RecoveredBlock<<DatabaseProvider<TX, N> as BlockReader>::Block>>, ProviderError>
fn block_with_senders_range( &self, range: RangeInclusive<u64>, ) -> Result<Vec<RecoveredBlock<<DatabaseProvider<TX, N> as BlockReader>::Block>>, ProviderError>
§fn sealed_block_with_senders_range(
&self,
range: RangeInclusive<u64>,
) -> Result<Vec<RecoveredBlock<<DatabaseProvider<TX, N> as BlockReader>::Block>>, ProviderError>
fn sealed_block_with_senders_range( &self, range: RangeInclusive<u64>, ) -> Result<Vec<RecoveredBlock<<DatabaseProvider<TX, N> as BlockReader>::Block>>, ProviderError>
§fn block_by_hash(
&self,
hash: FixedBytes<32>,
) -> Result<Option<Self::Block>, ProviderError>
fn block_by_hash( &self, hash: FixedBytes<32>, ) -> Result<Option<Self::Block>, ProviderError>
§fn block_by_number(
&self,
num: u64,
) -> Result<Option<Self::Block>, ProviderError>
fn block_by_number( &self, num: u64, ) -> Result<Option<Self::Block>, ProviderError>
§impl<TX, N> BlockWriter for DatabaseProvider<TX, N>where
TX: DbTxMut + DbTx + 'static,
N: NodeTypesForProvider + 'static,
impl<TX, N> BlockWriter for DatabaseProvider<TX, N>where
TX: DbTxMut + DbTx + 'static,
N: NodeTypesForProvider + 'static,
§fn insert_block(
&self,
block: RecoveredBlock<<DatabaseProvider<TX, N> as BlockWriter>::Block>,
write_to: StorageLocation,
) -> Result<StoredBlockBodyIndices, ProviderError>
fn insert_block( &self, block: RecoveredBlock<<DatabaseProvider<TX, N> as BlockWriter>::Block>, write_to: StorageLocation, ) -> Result<StoredBlockBodyIndices, ProviderError>
Inserts the block into the database, always modifying the following tables:
If there are transactions in the block, the following tables will be modified:
If ommers are not empty, this will modify BlockOmmers
.
If withdrawals are not empty, this will modify
BlockWithdrawals
.
If the provider has not configured full sender pruning, this will modify
TransactionSenders
.
If the provider has not configured full transaction lookup pruning, this will modify
TransactionHashNumbers
.
§fn append_blocks_with_state(
&self,
blocks: Vec<RecoveredBlock<<DatabaseProvider<TX, N> as BlockWriter>::Block>>,
execution_outcome: &ExecutionOutcome<<DatabaseProvider<TX, N> as BlockWriter>::Receipt>,
hashed_state: HashedPostStateSorted,
trie_updates: TrieUpdates,
) -> Result<(), ProviderError>
fn append_blocks_with_state( &self, blocks: Vec<RecoveredBlock<<DatabaseProvider<TX, N> as BlockWriter>::Block>>, execution_outcome: &ExecutionOutcome<<DatabaseProvider<TX, N> as BlockWriter>::Receipt>, hashed_state: HashedPostStateSorted, trie_updates: TrieUpdates, ) -> Result<(), ProviderError>
TODO(joshie): this fn should be moved to UnifiedStorageWriter
eventually
§type Block = <<N as NodeTypes>::Primitives as NodePrimitives>::Block
type Block = <<N as NodeTypes>::Primitives as NodePrimitives>::Block
§type Receipt = <<N as NodeTypes>::Primitives as NodePrimitives>::Receipt
type Receipt = <<N as NodeTypes>::Primitives as NodePrimitives>::Receipt
ExecutionOutcome
.§fn append_block_bodies(
&self,
bodies: Vec<(u64, Option<<<N as NodeTypes>::Primitives as NodePrimitives>::BlockBody>)>,
write_to: StorageLocation,
) -> Result<(), ProviderError>
fn append_block_bodies( &self, bodies: Vec<(u64, Option<<<N as NodeTypes>::Primitives as NodePrimitives>::BlockBody>)>, write_to: StorageLocation, ) -> Result<(), ProviderError>
Bodies
stage and does not write to TransactionHashNumbers
and TransactionSenders
tables which are populated on later stages. Read more§fn remove_blocks_above(
&self,
block: u64,
remove_from: StorageLocation,
) -> Result<(), ProviderError>
fn remove_blocks_above( &self, block: u64, remove_from: StorageLocation, ) -> Result<(), ProviderError>
§fn remove_bodies_above(
&self,
block: u64,
remove_from: StorageLocation,
) -> Result<(), ProviderError>
fn remove_bodies_above( &self, block: u64, remove_from: StorageLocation, ) -> Result<(), ProviderError>
§impl<TX, N> ChainSpecProvider for DatabaseProvider<TX, N>
impl<TX, N> ChainSpecProvider for DatabaseProvider<TX, N>
§fn chain_spec(
&self,
) -> Arc<<DatabaseProvider<TX, N> as ChainSpecProvider>::ChainSpec>
fn chain_spec( &self, ) -> Arc<<DatabaseProvider<TX, N> as ChainSpecProvider>::ChainSpec>
Arc
to the chainspec.§impl<TX, N> ChainStateBlockReader for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypes,
impl<TX, N> ChainStateBlockReader for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypes,
§fn last_finalized_block_number(&self) -> Result<Option<u64>, ProviderError>
fn last_finalized_block_number(&self) -> Result<Option<u64>, ProviderError>
§fn last_safe_block_number(&self) -> Result<Option<u64>, ProviderError>
fn last_safe_block_number(&self) -> Result<Option<u64>, ProviderError>
§impl<TX, N> ChainStateBlockWriter for DatabaseProvider<TX, N>where
TX: DbTxMut,
N: NodeTypes,
impl<TX, N> ChainStateBlockWriter for DatabaseProvider<TX, N>where
TX: DbTxMut,
N: NodeTypes,
§fn save_finalized_block_number(
&self,
block_number: u64,
) -> Result<(), ProviderError>
fn save_finalized_block_number( &self, block_number: u64, ) -> Result<(), ProviderError>
§fn save_safe_block_number(&self, block_number: u64) -> Result<(), ProviderError>
fn save_safe_block_number(&self, block_number: u64) -> Result<(), ProviderError>
§impl<TX, N> ChangeSetReader for DatabaseProvider<TX, N>where
TX: DbTx,
N: NodeTypes,
impl<TX, N> ChangeSetReader for DatabaseProvider<TX, N>where
TX: DbTx,
N: NodeTypes,
§fn account_block_changeset(
&self,
block_number: u64,
) -> Result<Vec<AccountBeforeTx>, ProviderError>
fn account_block_changeset( &self, block_number: u64, ) -> Result<Vec<AccountBeforeTx>, ProviderError>
§impl<TX, N> DBProvider for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypes + 'static,
impl<TX, N> DBProvider for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypes + 'static,
§fn tx_ref(&self) -> &<DatabaseProvider<TX, N> as DBProvider>::Tx
fn tx_ref(&self) -> &<DatabaseProvider<TX, N> as DBProvider>::Tx
§fn tx_mut(&mut self) -> &mut <DatabaseProvider<TX, N> as DBProvider>::Tx
fn tx_mut(&mut self) -> &mut <DatabaseProvider<TX, N> as DBProvider>::Tx
§fn into_tx(self) -> <DatabaseProvider<TX, N> as DBProvider>::Tx
fn into_tx(self) -> <DatabaseProvider<TX, N> as DBProvider>::Tx
§fn prune_modes_ref(&self) -> &PruneModes
fn prune_modes_ref(&self) -> &PruneModes
§fn disable_long_read_transaction_safety(self) -> Self
fn disable_long_read_transaction_safety(self) -> Self
§fn commit(self) -> Result<bool, ProviderError>
fn commit(self) -> Result<bool, ProviderError>
§fn table<T>(
&self,
) -> Result<Vec<(<T as Table>::Key, <T as Table>::Value)>, DatabaseError>
fn table<T>( &self, ) -> Result<Vec<(<T as Table>::Key, <T as Table>::Value)>, DatabaseError>
§fn get<T>(
&self,
range: impl RangeBounds<<T as Table>::Key>,
) -> Result<Vec<(<T as Table>::Key, <T as Table>::Value)>, DatabaseError>where
T: Table,
fn get<T>(
&self,
range: impl RangeBounds<<T as Table>::Key>,
) -> Result<Vec<(<T as Table>::Key, <T as Table>::Value)>, DatabaseError>where
T: Table,
§fn cursor_read_collect<T>(
&self,
range: impl RangeBounds<<T as Table>::Key>,
) -> Result<Vec<<T as Table>::Value>, ProviderError>where
T: Table<Key = u64>,
fn cursor_read_collect<T>(
&self,
range: impl RangeBounds<<T as Table>::Key>,
) -> Result<Vec<<T as Table>::Value>, ProviderError>where
T: Table<Key = u64>,
§fn cursor_collect<T>(
&self,
cursor: &mut impl DbCursorRO<T>,
range: impl RangeBounds<<T as Table>::Key>,
) -> Result<Vec<<T as Table>::Value>, ProviderError>where
T: Table<Key = u64>,
fn cursor_collect<T>(
&self,
cursor: &mut impl DbCursorRO<T>,
range: impl RangeBounds<<T as Table>::Key>,
) -> Result<Vec<<T as Table>::Value>, ProviderError>where
T: Table<Key = u64>,
§fn cursor_collect_with_capacity<T>(
&self,
cursor: &mut impl DbCursorRO<T>,
range: impl RangeBounds<<T as Table>::Key>,
capacity: usize,
) -> Result<Vec<<T as Table>::Value>, ProviderError>where
T: Table<Key = u64>,
fn cursor_collect_with_capacity<T>(
&self,
cursor: &mut impl DbCursorRO<T>,
range: impl RangeBounds<<T as Table>::Key>,
capacity: usize,
) -> Result<Vec<<T as Table>::Value>, ProviderError>where
T: Table<Key = u64>,
§fn remove<T>(
&self,
range: impl RangeBounds<<T as Table>::Key>,
) -> Result<usize, DatabaseError>where
T: Table,
Self::Tx: DbTxMut,
fn remove<T>(
&self,
range: impl RangeBounds<<T as Table>::Key>,
) -> Result<usize, DatabaseError>where
T: Table,
Self::Tx: DbTxMut,
§fn take<T>(
&self,
range: impl RangeBounds<<T as Table>::Key>,
) -> Result<Vec<(<T as Table>::Key, <T as Table>::Value)>, DatabaseError>where
T: Table,
Self::Tx: DbTxMut,
fn take<T>(
&self,
range: impl RangeBounds<<T as Table>::Key>,
) -> Result<Vec<(<T as Table>::Key, <T as Table>::Value)>, DatabaseError>where
T: Table,
Self::Tx: DbTxMut,
§impl<TX, N> Debug for DatabaseProvider<TX, N>
impl<TX, N> Debug for DatabaseProvider<TX, N>
§impl<DB, N> From<DatabaseProviderRW<DB, N>> for DatabaseProvider<<DB as Database>::TXMut, N>where
DB: Database,
N: NodeTypes,
impl<DB, N> From<DatabaseProviderRW<DB, N>> for DatabaseProvider<<DB as Database>::TXMut, N>where
DB: Database,
N: NodeTypes,
§fn from(
provider: DatabaseProviderRW<DB, N>,
) -> DatabaseProvider<<DB as Database>::TXMut, N>
fn from( provider: DatabaseProviderRW<DB, N>, ) -> DatabaseProvider<<DB as Database>::TXMut, N>
§impl<TX, N> HashingWriter for DatabaseProvider<TX, N>where
TX: DbTxMut + DbTx + 'static,
N: NodeTypes,
impl<TX, N> HashingWriter for DatabaseProvider<TX, N>where
TX: DbTxMut + DbTx + 'static,
N: NodeTypes,
§fn unwind_account_hashing<'a>(
&self,
changesets: impl Iterator<Item = &'a (u64, AccountBeforeTx)>,
) -> Result<BTreeMap<FixedBytes<32>, Option<Account>>, ProviderError>
fn unwind_account_hashing<'a>( &self, changesets: impl Iterator<Item = &'a (u64, AccountBeforeTx)>, ) -> Result<BTreeMap<FixedBytes<32>, Option<Account>>, ProviderError>
§fn unwind_account_hashing_range(
&self,
range: impl RangeBounds<u64>,
) -> Result<BTreeMap<FixedBytes<32>, Option<Account>>, ProviderError>
fn unwind_account_hashing_range( &self, range: impl RangeBounds<u64>, ) -> Result<BTreeMap<FixedBytes<32>, Option<Account>>, ProviderError>
§fn insert_account_for_hashing(
&self,
changesets: impl IntoIterator<Item = (Address, Option<Account>)>,
) -> Result<BTreeMap<FixedBytes<32>, Option<Account>>, ProviderError>
fn insert_account_for_hashing( &self, changesets: impl IntoIterator<Item = (Address, Option<Account>)>, ) -> Result<BTreeMap<FixedBytes<32>, Option<Account>>, ProviderError>
AccountsHistory
][reth_db_api::tables::AccountsHistory] table. Read more§fn unwind_storage_hashing(
&self,
changesets: impl Iterator<Item = (BlockNumberAddress, StorageEntry)>,
) -> Result<HashMap<FixedBytes<32>, BTreeSet<FixedBytes<32>>, RandomState>, ProviderError>
fn unwind_storage_hashing( &self, changesets: impl Iterator<Item = (BlockNumberAddress, StorageEntry)>, ) -> Result<HashMap<FixedBytes<32>, BTreeSet<FixedBytes<32>>, RandomState>, ProviderError>
§fn unwind_storage_hashing_range(
&self,
range: impl RangeBounds<BlockNumberAddress>,
) -> Result<HashMap<FixedBytes<32>, BTreeSet<FixedBytes<32>>, RandomState>, ProviderError>
fn unwind_storage_hashing_range( &self, range: impl RangeBounds<BlockNumberAddress>, ) -> Result<HashMap<FixedBytes<32>, BTreeSet<FixedBytes<32>>, RandomState>, ProviderError>
§fn insert_storage_for_hashing(
&self,
storages: impl IntoIterator<Item = (Address, impl IntoIterator<Item = StorageEntry>)>,
) -> Result<HashMap<FixedBytes<32>, BTreeSet<FixedBytes<32>>, RandomState>, ProviderError>
fn insert_storage_for_hashing( &self, storages: impl IntoIterator<Item = (Address, impl IntoIterator<Item = StorageEntry>)>, ) -> Result<HashMap<FixedBytes<32>, BTreeSet<FixedBytes<32>>, RandomState>, ProviderError>
§fn insert_hashes(
&self,
range: RangeInclusive<u64>,
end_block_hash: FixedBytes<32>,
expected_state_root: FixedBytes<32>,
) -> Result<(), ProviderError>
fn insert_hashes( &self, range: RangeInclusive<u64>, end_block_hash: FixedBytes<32>, expected_state_root: FixedBytes<32>, ) -> Result<(), ProviderError>
§impl<TX, N> HeaderProvider for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypesForProvider,
impl<TX, N> HeaderProvider for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypesForProvider,
§type Header = <<N as NodeTypes>::Primitives as NodePrimitives>::BlockHeader
type Header = <<N as NodeTypes>::Primitives as NodePrimitives>::BlockHeader
§fn header(
&self,
block_hash: &FixedBytes<32>,
) -> Result<Option<<DatabaseProvider<TX, N> as HeaderProvider>::Header>, ProviderError>
fn header( &self, block_hash: &FixedBytes<32>, ) -> Result<Option<<DatabaseProvider<TX, N> as HeaderProvider>::Header>, ProviderError>
§fn header_by_number(
&self,
num: u64,
) -> Result<Option<<DatabaseProvider<TX, N> as HeaderProvider>::Header>, ProviderError>
fn header_by_number( &self, num: u64, ) -> Result<Option<<DatabaseProvider<TX, N> as HeaderProvider>::Header>, ProviderError>
§fn header_td(
&self,
block_hash: &FixedBytes<32>,
) -> Result<Option<Uint<256, 4>>, ProviderError>
fn header_td( &self, block_hash: &FixedBytes<32>, ) -> Result<Option<Uint<256, 4>>, ProviderError>
§fn header_td_by_number(
&self,
number: u64,
) -> Result<Option<Uint<256, 4>>, ProviderError>
fn header_td_by_number( &self, number: u64, ) -> Result<Option<Uint<256, 4>>, ProviderError>
§fn headers_range(
&self,
range: impl RangeBounds<u64>,
) -> Result<Vec<<DatabaseProvider<TX, N> as HeaderProvider>::Header>, ProviderError>
fn headers_range( &self, range: impl RangeBounds<u64>, ) -> Result<Vec<<DatabaseProvider<TX, N> as HeaderProvider>::Header>, ProviderError>
§fn sealed_header(
&self,
number: u64,
) -> Result<Option<SealedHeader<<DatabaseProvider<TX, N> as HeaderProvider>::Header>>, ProviderError>
fn sealed_header( &self, number: u64, ) -> Result<Option<SealedHeader<<DatabaseProvider<TX, N> as HeaderProvider>::Header>>, ProviderError>
§fn sealed_headers_while(
&self,
range: impl RangeBounds<u64>,
predicate: impl FnMut(&SealedHeader<<DatabaseProvider<TX, N> as HeaderProvider>::Header>) -> bool,
) -> Result<Vec<SealedHeader<<DatabaseProvider<TX, N> as HeaderProvider>::Header>>, ProviderError>
fn sealed_headers_while( &self, range: impl RangeBounds<u64>, predicate: impl FnMut(&SealedHeader<<DatabaseProvider<TX, N> as HeaderProvider>::Header>) -> bool, ) -> Result<Vec<SealedHeader<<DatabaseProvider<TX, N> as HeaderProvider>::Header>>, ProviderError>
predicate
returns true
or the range is exhausted.§fn is_known(&self, block_hash: &FixedBytes<32>) -> Result<bool, ProviderError>
fn is_known(&self, block_hash: &FixedBytes<32>) -> Result<bool, ProviderError>
§fn sealed_header_by_hash(
&self,
block_hash: FixedBytes<32>,
) -> Result<Option<SealedHeader<Self::Header>>, ProviderError>
fn sealed_header_by_hash( &self, block_hash: FixedBytes<32>, ) -> Result<Option<SealedHeader<Self::Header>>, ProviderError>
§fn header_by_hash_or_number(
&self,
hash_or_num: HashOrNumber,
) -> Result<Option<Self::Header>, ProviderError>
fn header_by_hash_or_number( &self, hash_or_num: HashOrNumber, ) -> Result<Option<Self::Header>, ProviderError>
§fn sealed_headers_range(
&self,
range: impl RangeBounds<u64>,
) -> Result<Vec<SealedHeader<Self::Header>>, ProviderError>
fn sealed_headers_range( &self, range: impl RangeBounds<u64>, ) -> Result<Vec<SealedHeader<Self::Header>>, ProviderError>
§impl<TX, N> HeaderSyncGapProvider for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypesForProvider,
impl<TX, N> HeaderSyncGapProvider for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypesForProvider,
§type Header = <<N as NodeTypes>::Primitives as NodePrimitives>::BlockHeader
type Header = <<N as NodeTypes>::Primitives as NodePrimitives>::BlockHeader
§fn sync_gap(
&self,
tip: Receiver<FixedBytes<32>>,
highest_uninterrupted_block: u64,
) -> Result<HeaderSyncGap<<DatabaseProvider<TX, N> as HeaderSyncGapProvider>::Header>, ProviderError>
fn sync_gap( &self, tip: Receiver<FixedBytes<32>>, highest_uninterrupted_block: u64, ) -> Result<HeaderSyncGap<<DatabaseProvider<TX, N> as HeaderSyncGapProvider>::Header>, ProviderError>
§impl<TX, N> HistoryWriter for DatabaseProvider<TX, N>where
TX: DbTxMut + DbTx + 'static,
N: NodeTypes,
impl<TX, N> HistoryWriter for DatabaseProvider<TX, N>where
TX: DbTxMut + DbTx + 'static,
N: NodeTypes,
§fn unwind_account_history_indices<'a>(
&self,
changesets: impl Iterator<Item = &'a (u64, AccountBeforeTx)>,
) -> Result<usize, ProviderError>
fn unwind_account_history_indices<'a>( &self, changesets: impl Iterator<Item = &'a (u64, AccountBeforeTx)>, ) -> Result<usize, ProviderError>
§fn unwind_account_history_indices_range(
&self,
range: impl RangeBounds<u64>,
) -> Result<usize, ProviderError>
fn unwind_account_history_indices_range( &self, range: impl RangeBounds<u64>, ) -> Result<usize, ProviderError>
§fn insert_account_history_index(
&self,
account_transitions: impl IntoIterator<Item = (Address, impl IntoIterator<Item = u64>)>,
) -> Result<(), ProviderError>
fn insert_account_history_index( &self, account_transitions: impl IntoIterator<Item = (Address, impl IntoIterator<Item = u64>)>, ) -> Result<(), ProviderError>
§fn unwind_storage_history_indices(
&self,
changesets: impl Iterator<Item = (BlockNumberAddress, StorageEntry)>,
) -> Result<usize, ProviderError>
fn unwind_storage_history_indices( &self, changesets: impl Iterator<Item = (BlockNumberAddress, StorageEntry)>, ) -> Result<usize, ProviderError>
§fn unwind_storage_history_indices_range(
&self,
range: impl RangeBounds<BlockNumberAddress>,
) -> Result<usize, ProviderError>
fn unwind_storage_history_indices_range( &self, range: impl RangeBounds<BlockNumberAddress>, ) -> Result<usize, ProviderError>
§fn insert_storage_history_index(
&self,
storage_transitions: impl IntoIterator<Item = ((Address, FixedBytes<32>), impl IntoIterator<Item = u64>)>,
) -> Result<(), ProviderError>
fn insert_storage_history_index( &self, storage_transitions: impl IntoIterator<Item = ((Address, FixedBytes<32>), impl IntoIterator<Item = u64>)>, ) -> Result<(), ProviderError>
§fn update_history_indices(
&self,
range: RangeInclusive<u64>,
) -> Result<(), ProviderError>
fn update_history_indices( &self, range: RangeInclusive<u64>, ) -> Result<(), ProviderError>
§impl<TX, N> NodePrimitivesProvider for DatabaseProvider<TX, N>where
N: NodeTypes,
impl<TX, N> NodePrimitivesProvider for DatabaseProvider<TX, N>where
N: NodeTypes,
§type Primitives = <N as NodeTypes>::Primitives
type Primitives = <N as NodeTypes>::Primitives
§impl<TX, N> OmmersProvider for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypesForProvider,
impl<TX, N> OmmersProvider for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypesForProvider,
§fn ommers(
&self,
id: HashOrNumber,
) -> Result<Option<Vec<<DatabaseProvider<TX, N> as HeaderProvider>::Header>>, ProviderError>
fn ommers( &self, id: HashOrNumber, ) -> Result<Option<Vec<<DatabaseProvider<TX, N> as HeaderProvider>::Header>>, ProviderError>
Returns the ommers for the block with matching id from the database.
If the block is not found, this returns None
.
If the block exists, but doesn’t contain ommers, this returns None
.
§impl<TX, N> PruneCheckpointReader for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypes,
impl<TX, N> PruneCheckpointReader for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypes,
§fn get_prune_checkpoint(
&self,
segment: PruneSegment,
) -> Result<Option<PruneCheckpoint>, ProviderError>
fn get_prune_checkpoint( &self, segment: PruneSegment, ) -> Result<Option<PruneCheckpoint>, ProviderError>
§fn get_prune_checkpoints(
&self,
) -> Result<Vec<(PruneSegment, PruneCheckpoint)>, ProviderError>
fn get_prune_checkpoints( &self, ) -> Result<Vec<(PruneSegment, PruneCheckpoint)>, ProviderError>
§impl<TX, N> PruneCheckpointWriter for DatabaseProvider<TX, N>where
TX: DbTxMut,
N: NodeTypes,
impl<TX, N> PruneCheckpointWriter for DatabaseProvider<TX, N>where
TX: DbTxMut,
N: NodeTypes,
§fn save_prune_checkpoint(
&self,
segment: PruneSegment,
checkpoint: PruneCheckpoint,
) -> Result<(), ProviderError>
fn save_prune_checkpoint( &self, segment: PruneSegment, checkpoint: PruneCheckpoint, ) -> Result<(), ProviderError>
§impl<TX, N> ReceiptProvider for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypesForProvider,
impl<TX, N> ReceiptProvider for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypesForProvider,
§type Receipt = <<N as NodeTypes>::Primitives as NodePrimitives>::Receipt
type Receipt = <<N as NodeTypes>::Primitives as NodePrimitives>::Receipt
§fn receipt(
&self,
id: u64,
) -> Result<Option<<DatabaseProvider<TX, N> as ReceiptProvider>::Receipt>, ProviderError>
fn receipt( &self, id: u64, ) -> Result<Option<<DatabaseProvider<TX, N> as ReceiptProvider>::Receipt>, ProviderError>
§fn receipt_by_hash(
&self,
hash: FixedBytes<32>,
) -> Result<Option<<DatabaseProvider<TX, N> as ReceiptProvider>::Receipt>, ProviderError>
fn receipt_by_hash( &self, hash: FixedBytes<32>, ) -> Result<Option<<DatabaseProvider<TX, N> as ReceiptProvider>::Receipt>, ProviderError>
§fn receipts_by_block(
&self,
block: HashOrNumber,
) -> Result<Option<Vec<<DatabaseProvider<TX, N> as ReceiptProvider>::Receipt>>, ProviderError>
fn receipts_by_block( &self, block: HashOrNumber, ) -> Result<Option<Vec<<DatabaseProvider<TX, N> as ReceiptProvider>::Receipt>>, ProviderError>
§fn receipts_by_tx_range(
&self,
range: impl RangeBounds<u64>,
) -> Result<Vec<<DatabaseProvider<TX, N> as ReceiptProvider>::Receipt>, ProviderError>
fn receipts_by_tx_range( &self, range: impl RangeBounds<u64>, ) -> Result<Vec<<DatabaseProvider<TX, N> as ReceiptProvider>::Receipt>, ProviderError>
§impl<TX, N> StageCheckpointReader for DatabaseProvider<TX, N>where
TX: DbTx,
N: NodeTypes,
impl<TX, N> StageCheckpointReader for DatabaseProvider<TX, N>where
TX: DbTx,
N: NodeTypes,
§fn get_stage_checkpoint_progress(
&self,
id: StageId,
) -> Result<Option<Vec<u8>>, ProviderError>
fn get_stage_checkpoint_progress( &self, id: StageId, ) -> Result<Option<Vec<u8>>, ProviderError>
Get stage checkpoint progress.
§fn get_stage_checkpoint(
&self,
id: StageId,
) -> Result<Option<StageCheckpoint>, ProviderError>
fn get_stage_checkpoint( &self, id: StageId, ) -> Result<Option<StageCheckpoint>, ProviderError>
§fn get_all_checkpoints(
&self,
) -> Result<Vec<(String, StageCheckpoint)>, ProviderError>
fn get_all_checkpoints( &self, ) -> Result<Vec<(String, StageCheckpoint)>, ProviderError>
§impl<TX, N> StageCheckpointWriter for DatabaseProvider<TX, N>where
TX: DbTxMut,
N: NodeTypes,
impl<TX, N> StageCheckpointWriter for DatabaseProvider<TX, N>where
TX: DbTxMut,
N: NodeTypes,
§fn save_stage_checkpoint(
&self,
id: StageId,
checkpoint: StageCheckpoint,
) -> Result<(), ProviderError>
fn save_stage_checkpoint( &self, id: StageId, checkpoint: StageCheckpoint, ) -> Result<(), ProviderError>
Save stage checkpoint.
§fn save_stage_checkpoint_progress(
&self,
id: StageId,
checkpoint: Vec<u8>,
) -> Result<(), ProviderError>
fn save_stage_checkpoint_progress( &self, id: StageId, checkpoint: Vec<u8>, ) -> Result<(), ProviderError>
Save stage checkpoint progress.
§fn update_pipeline_stages(
&self,
block_number: u64,
drop_stage_checkpoint: bool,
) -> Result<(), ProviderError>
fn update_pipeline_stages( &self, block_number: u64, drop_stage_checkpoint: bool, ) -> Result<(), ProviderError>
§impl<TX, N> StateCommitmentProvider for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypes,
impl<TX, N> StateCommitmentProvider for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypes,
§type StateCommitment = <N as NodeTypes>::StateCommitment
type StateCommitment = <N as NodeTypes>::StateCommitment
StateCommitment
] type that can be used to perform state commitment operations.§impl<TX, N> StateWriter for DatabaseProvider<TX, N>where
TX: DbTxMut + DbTx + 'static,
N: NodeTypesForProvider,
impl<TX, N> StateWriter for DatabaseProvider<TX, N>where
TX: DbTxMut + DbTx + 'static,
N: NodeTypesForProvider,
§fn remove_state_above(
&self,
block: u64,
remove_receipts_from: StorageLocation,
) -> Result<(), ProviderError>
fn remove_state_above( &self, block: u64, remove_receipts_from: StorageLocation, ) -> Result<(), ProviderError>
Remove the last N blocks of state.
The latest state will be unwound
- Iterate over the [
BlockBodyIndices
][tables::BlockBodyIndices] table to get all the transaction ids. - Iterate over the [
StorageChangeSets
][tables::StorageChangeSets] table and the [AccountChangeSets
][tables::AccountChangeSets] tables in reverse order to reconstruct the changesets.- In order to have both the old and new values in the changesets, we also access the plain state tables.
- While iterating over the changeset tables, if we encounter a new account or storage slot,
we:
- Take the old value from the changeset
- Take the new value from the plain state
- Save the old value to the local state
- While iterating over the changeset tables, if we encounter an account/storage slot we
have seen before we:
- Take the old value from the changeset
- Take the new value from the local state
- Set the local state to the value in the changeset
§fn take_state_above(
&self,
block: u64,
remove_receipts_from: StorageLocation,
) -> Result<ExecutionOutcome<<DatabaseProvider<TX, N> as StateWriter>::Receipt>, ProviderError>
fn take_state_above( &self, block: u64, remove_receipts_from: StorageLocation, ) -> Result<ExecutionOutcome<<DatabaseProvider<TX, N> as StateWriter>::Receipt>, ProviderError>
Take the last N blocks of state, recreating the ExecutionOutcome
.
The latest state will be unwound and returned back with all the blocks
- Iterate over the [
BlockBodyIndices
][tables::BlockBodyIndices] table to get all the transaction ids. - Iterate over the [
StorageChangeSets
][tables::StorageChangeSets] table and the [AccountChangeSets
][tables::AccountChangeSets] tables in reverse order to reconstruct the changesets.- In order to have both the old and new values in the changesets, we also access the plain state tables.
- While iterating over the changeset tables, if we encounter a new account or storage slot,
we:
- Take the old value from the changeset
- Take the new value from the plain state
- Save the old value to the local state
- While iterating over the changeset tables, if we encounter an account/storage slot we
have seen before we:
- Take the old value from the changeset
- Take the new value from the local state
- Set the local state to the value in the changeset
§type Receipt = <<N as NodeTypes>::Primitives as NodePrimitives>::Receipt
type Receipt = <<N as NodeTypes>::Primitives as NodePrimitives>::Receipt
ExecutionOutcome
.§fn write_state(
&self,
execution_outcome: &ExecutionOutcome<<DatabaseProvider<TX, N> as StateWriter>::Receipt>,
is_value_known: OriginalValuesKnown,
write_receipts_to: StorageLocation,
) -> Result<(), ProviderError>
fn write_state( &self, execution_outcome: &ExecutionOutcome<<DatabaseProvider<TX, N> as StateWriter>::Receipt>, is_value_known: OriginalValuesKnown, write_receipts_to: StorageLocation, ) -> Result<(), ProviderError>
static_file_producer
is
Some
. It should be None
if there is any kind of pruning/filtering over the receipts.§fn write_state_reverts(
&self,
reverts: PlainStateReverts,
first_block: u64,
) -> Result<(), ProviderError>
fn write_state_reverts( &self, reverts: PlainStateReverts, first_block: u64, ) -> Result<(), ProviderError>
§fn write_state_changes(
&self,
changes: StateChangeset,
) -> Result<(), ProviderError>
fn write_state_changes( &self, changes: StateChangeset, ) -> Result<(), ProviderError>
§fn write_hashed_state(
&self,
hashed_state: &HashedPostStateSorted,
) -> Result<(), ProviderError>
fn write_hashed_state( &self, hashed_state: &HashedPostStateSorted, ) -> Result<(), ProviderError>
§impl<TX, N> StaticFileProviderFactory for DatabaseProvider<TX, N>where
N: NodeTypes,
impl<TX, N> StaticFileProviderFactory for DatabaseProvider<TX, N>where
N: NodeTypes,
§fn static_file_provider(
&self,
) -> StaticFileProvider<<DatabaseProvider<TX, N> as NodePrimitivesProvider>::Primitives>
fn static_file_provider( &self, ) -> StaticFileProvider<<DatabaseProvider<TX, N> as NodePrimitivesProvider>::Primitives>
Returns a static file provider
§impl<TX, N> StatsReader for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypesForProvider,
impl<TX, N> StatsReader for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypesForProvider,
§fn count_entries<T>(&self) -> Result<usize, ProviderError>where
T: Table,
fn count_entries<T>(&self) -> Result<usize, ProviderError>where
T: Table,
§impl<TX, N> StorageChangeSetReader for DatabaseProvider<TX, N>where
TX: DbTx,
N: NodeTypes,
impl<TX, N> StorageChangeSetReader for DatabaseProvider<TX, N>where
TX: DbTx,
N: NodeTypes,
§fn storage_changeset(
&self,
block_number: u64,
) -> Result<Vec<(BlockNumberAddress, StorageEntry)>, ProviderError>
fn storage_changeset( &self, block_number: u64, ) -> Result<Vec<(BlockNumberAddress, StorageEntry)>, ProviderError>
§impl<TX, N> StorageReader for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypes,
impl<TX, N> StorageReader for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypes,
§fn plain_state_storages(
&self,
addresses_with_keys: impl IntoIterator<Item = (Address, impl IntoIterator<Item = FixedBytes<32>>)>,
) -> Result<Vec<(Address, Vec<StorageEntry>)>, ProviderError>
fn plain_state_storages( &self, addresses_with_keys: impl IntoIterator<Item = (Address, impl IntoIterator<Item = FixedBytes<32>>)>, ) -> Result<Vec<(Address, Vec<StorageEntry>)>, ProviderError>
§fn changed_storages_with_range(
&self,
range: RangeInclusive<u64>,
) -> Result<BTreeMap<Address, BTreeSet<FixedBytes<32>>>, ProviderError>
fn changed_storages_with_range( &self, range: RangeInclusive<u64>, ) -> Result<BTreeMap<Address, BTreeSet<FixedBytes<32>>>, ProviderError>
§fn changed_storages_and_blocks_with_range(
&self,
range: RangeInclusive<u64>,
) -> Result<BTreeMap<(Address, FixedBytes<32>), Vec<u64>>, ProviderError>
fn changed_storages_and_blocks_with_range( &self, range: RangeInclusive<u64>, ) -> Result<BTreeMap<(Address, FixedBytes<32>), Vec<u64>>, ProviderError>
§impl<TX, N> StorageTrieWriter for DatabaseProvider<TX, N>where
TX: DbTxMut + DbTx + 'static,
N: NodeTypes,
impl<TX, N> StorageTrieWriter for DatabaseProvider<TX, N>where
TX: DbTxMut + DbTx + 'static,
N: NodeTypes,
§fn write_storage_trie_updates(
&self,
storage_tries: &HashMap<FixedBytes<32>, StorageTrieUpdates, FbBuildHasher<32>>,
) -> Result<usize, ProviderError>
fn write_storage_trie_updates( &self, storage_tries: &HashMap<FixedBytes<32>, StorageTrieUpdates, FbBuildHasher<32>>, ) -> Result<usize, ProviderError>
Writes storage trie updates from the given storage trie map. First sorts the storage trie updates by the hashed address, writing in sorted order.
§fn write_individual_storage_trie_updates(
&self,
hashed_address: FixedBytes<32>,
updates: &StorageTrieUpdates,
) -> Result<usize, ProviderError>
fn write_individual_storage_trie_updates( &self, hashed_address: FixedBytes<32>, updates: &StorageTrieUpdates, ) -> Result<usize, ProviderError>
§impl<TX, N> TransactionsProvider for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypesForProvider,
impl<TX, N> TransactionsProvider for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypesForProvider,
§type Transaction = <<N as NodeTypes>::Primitives as NodePrimitives>::SignedTx
type Transaction = <<N as NodeTypes>::Primitives as NodePrimitives>::SignedTx
§fn transaction_id(
&self,
tx_hash: FixedBytes<32>,
) -> Result<Option<u64>, ProviderError>
fn transaction_id( &self, tx_hash: FixedBytes<32>, ) -> Result<Option<u64>, ProviderError>
§fn transaction_by_id(
&self,
id: u64,
) -> Result<Option<<DatabaseProvider<TX, N> as TransactionsProvider>::Transaction>, ProviderError>
fn transaction_by_id( &self, id: u64, ) -> Result<Option<<DatabaseProvider<TX, N> as TransactionsProvider>::Transaction>, ProviderError>
§fn transaction_by_id_unhashed(
&self,
id: u64,
) -> Result<Option<<DatabaseProvider<TX, N> as TransactionsProvider>::Transaction>, ProviderError>
fn transaction_by_id_unhashed( &self, id: u64, ) -> Result<Option<<DatabaseProvider<TX, N> as TransactionsProvider>::Transaction>, ProviderError>
§fn transaction_by_hash(
&self,
hash: FixedBytes<32>,
) -> Result<Option<<DatabaseProvider<TX, N> as TransactionsProvider>::Transaction>, ProviderError>
fn transaction_by_hash( &self, hash: FixedBytes<32>, ) -> Result<Option<<DatabaseProvider<TX, N> as TransactionsProvider>::Transaction>, ProviderError>
§fn transaction_by_hash_with_meta(
&self,
tx_hash: FixedBytes<32>,
) -> Result<Option<(<DatabaseProvider<TX, N> as TransactionsProvider>::Transaction, TransactionMeta)>, ProviderError>
fn transaction_by_hash_with_meta( &self, tx_hash: FixedBytes<32>, ) -> Result<Option<(<DatabaseProvider<TX, N> as TransactionsProvider>::Transaction, TransactionMeta)>, ProviderError>
§fn transaction_block(&self, id: u64) -> Result<Option<u64>, ProviderError>
fn transaction_block(&self, id: u64) -> Result<Option<u64>, ProviderError>
§fn transactions_by_block(
&self,
id: HashOrNumber,
) -> Result<Option<Vec<<DatabaseProvider<TX, N> as TransactionsProvider>::Transaction>>, ProviderError>
fn transactions_by_block( &self, id: HashOrNumber, ) -> Result<Option<Vec<<DatabaseProvider<TX, N> as TransactionsProvider>::Transaction>>, ProviderError>
§fn transactions_by_block_range(
&self,
range: impl RangeBounds<u64>,
) -> Result<Vec<Vec<<DatabaseProvider<TX, N> as TransactionsProvider>::Transaction>>, ProviderError>
fn transactions_by_block_range( &self, range: impl RangeBounds<u64>, ) -> Result<Vec<Vec<<DatabaseProvider<TX, N> as TransactionsProvider>::Transaction>>, ProviderError>
§fn transactions_by_tx_range(
&self,
range: impl RangeBounds<u64>,
) -> Result<Vec<<DatabaseProvider<TX, N> as TransactionsProvider>::Transaction>, ProviderError>
fn transactions_by_tx_range( &self, range: impl RangeBounds<u64>, ) -> Result<Vec<<DatabaseProvider<TX, N> as TransactionsProvider>::Transaction>, ProviderError>
§fn senders_by_tx_range(
&self,
range: impl RangeBounds<u64>,
) -> Result<Vec<Address>, ProviderError>
fn senders_by_tx_range( &self, range: impl RangeBounds<u64>, ) -> Result<Vec<Address>, ProviderError>
§fn transaction_sender(&self, id: u64) -> Result<Option<Address>, ProviderError>
fn transaction_sender(&self, id: u64) -> Result<Option<Address>, ProviderError>
§impl<TX, N> TransactionsProviderExt for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypesForProvider,
impl<TX, N> TransactionsProviderExt for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypesForProvider,
§fn transaction_hashes_by_range(
&self,
tx_range: Range<u64>,
) -> Result<Vec<(FixedBytes<32>, u64)>, ProviderError>
fn transaction_hashes_by_range( &self, tx_range: Range<u64>, ) -> Result<Vec<(FixedBytes<32>, u64)>, ProviderError>
Recovers transaction hashes by walking through Transactions
table and
calculating them in a parallel manner. Returned unsorted.
§fn transaction_range_by_block_range(
&self,
block_range: RangeInclusive<u64>,
) -> Result<RangeInclusive<u64>, ProviderError>
fn transaction_range_by_block_range( &self, block_range: RangeInclusive<u64>, ) -> Result<RangeInclusive<u64>, ProviderError>
§impl<TX, N> TrieWriter for DatabaseProvider<TX, N>where
TX: DbTxMut + DbTx + 'static,
N: NodeTypes,
impl<TX, N> TrieWriter for DatabaseProvider<TX, N>where
TX: DbTxMut + DbTx + 'static,
N: NodeTypes,
§fn write_trie_updates(
&self,
trie_updates: &TrieUpdates,
) -> Result<usize, ProviderError>
fn write_trie_updates( &self, trie_updates: &TrieUpdates, ) -> Result<usize, ProviderError>
Writes trie updates. Returns the number of entries modified.
§impl<TX, N> TryIntoHistoricalStateProvider for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypes,
impl<TX, N> TryIntoHistoricalStateProvider for DatabaseProvider<TX, N>where
TX: DbTx + 'static,
N: NodeTypes,
§fn try_into_history_at_block(
self,
block_number: u64,
) -> Result<Box<dyn StateProvider>, ProviderError>
fn try_into_history_at_block( self, block_number: u64, ) -> Result<Box<dyn StateProvider>, ProviderError>
StateProvider
indexed by the given historic block number.§impl<TX, N> WithdrawalsProvider for DatabaseProvider<TX, N>
impl<TX, N> WithdrawalsProvider for DatabaseProvider<TX, N>
§fn withdrawals_by_block(
&self,
id: HashOrNumber,
timestamp: u64,
) -> Result<Option<Withdrawals>, ProviderError>
fn withdrawals_by_block( &self, id: HashOrNumber, timestamp: u64, ) -> Result<Option<Withdrawals>, ProviderError>
Auto Trait Implementations§
impl<TX, N> Freeze for DatabaseProvider<TX, N>where
TX: Freeze,
impl<TX, N> !RefUnwindSafe for DatabaseProvider<TX, N>
impl<TX, N> Send for DatabaseProvider<TX, N>where
TX: Send,
impl<TX, N> Sync for DatabaseProvider<TX, N>where
TX: Sync,
impl<TX, N> Unpin for DatabaseProvider<TX, N>where
TX: Unpin,
impl<TX, N> !UnwindSafe for DatabaseProvider<TX, N>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
§impl<T> Conv for T
impl<T> Conv for T
§impl<T> FmtForward for T
impl<T> FmtForward for T
§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
self
to use its Binary
implementation when Debug
-formatted.§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
self
to use its Display
implementation when
Debug
-formatted.§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
self
to use its LowerExp
implementation when
Debug
-formatted.§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
self
to use its LowerHex
implementation when
Debug
-formatted.§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
self
to use its Octal
implementation when Debug
-formatted.§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
self
to use its Pointer
implementation when
Debug
-formatted.§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
self
to use its UpperExp
implementation when
Debug
-formatted.§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
self
to use its UpperHex
implementation when
Debug
-formatted.§fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more§impl<T> Paint for Twhere
T: ?Sized,
impl<T> Paint for Twhere
T: ?Sized,
§fn fg(&self, value: Color) -> Painted<&T>
fn fg(&self, value: Color) -> Painted<&T>
Returns a styled value derived from self
with the foreground set to
value
.
This method should be used rarely. Instead, prefer to use color-specific
builder methods like red()
and
green()
, which have the same functionality but are
pithier.
§Example
Set foreground color to white using fg()
:
use yansi::{Paint, Color};
painted.fg(Color::White);
Set foreground color to white using white()
.
use yansi::Paint;
painted.white();
§fn bright_black(&self) -> Painted<&T>
fn bright_black(&self) -> Painted<&T>
§fn bright_red(&self) -> Painted<&T>
fn bright_red(&self) -> Painted<&T>
§fn bright_green(&self) -> Painted<&T>
fn bright_green(&self) -> Painted<&T>
§fn bright_yellow(&self) -> Painted<&T>
fn bright_yellow(&self) -> Painted<&T>
§fn bright_blue(&self) -> Painted<&T>
fn bright_blue(&self) -> Painted<&T>
§fn bright_magenta(&self) -> Painted<&T>
fn bright_magenta(&self) -> Painted<&T>
§fn bright_cyan(&self) -> Painted<&T>
fn bright_cyan(&self) -> Painted<&T>
§fn bright_white(&self) -> Painted<&T>
fn bright_white(&self) -> Painted<&T>
§fn bg(&self, value: Color) -> Painted<&T>
fn bg(&self, value: Color) -> Painted<&T>
Returns a styled value derived from self
with the background set to
value
.
This method should be used rarely. Instead, prefer to use color-specific
builder methods like on_red()
and
on_green()
, which have the same functionality but
are pithier.
§Example
Set background color to red using fg()
:
use yansi::{Paint, Color};
painted.bg(Color::Red);
Set background color to red using on_red()
.
use yansi::Paint;
painted.on_red();
§fn on_primary(&self) -> Painted<&T>
fn on_primary(&self) -> Painted<&T>
§fn on_magenta(&self) -> Painted<&T>
fn on_magenta(&self) -> Painted<&T>
§fn on_bright_black(&self) -> Painted<&T>
fn on_bright_black(&self) -> Painted<&T>
§fn on_bright_red(&self) -> Painted<&T>
fn on_bright_red(&self) -> Painted<&T>
§fn on_bright_green(&self) -> Painted<&T>
fn on_bright_green(&self) -> Painted<&T>
§fn on_bright_yellow(&self) -> Painted<&T>
fn on_bright_yellow(&self) -> Painted<&T>
§fn on_bright_blue(&self) -> Painted<&T>
fn on_bright_blue(&self) -> Painted<&T>
§fn on_bright_magenta(&self) -> Painted<&T>
fn on_bright_magenta(&self) -> Painted<&T>
§fn on_bright_cyan(&self) -> Painted<&T>
fn on_bright_cyan(&self) -> Painted<&T>
§fn on_bright_white(&self) -> Painted<&T>
fn on_bright_white(&self) -> Painted<&T>
§fn attr(&self, value: Attribute) -> Painted<&T>
fn attr(&self, value: Attribute) -> Painted<&T>
Enables the styling [Attribute
] value
.
This method should be used rarely. Instead, prefer to use
attribute-specific builder methods like bold()
and
underline()
, which have the same functionality
but are pithier.
§Example
Make text bold using attr()
:
use yansi::{Paint, Attribute};
painted.attr(Attribute::Bold);
Make text bold using using bold()
.
use yansi::Paint;
painted.bold();
§fn rapid_blink(&self) -> Painted<&T>
fn rapid_blink(&self) -> Painted<&T>
§fn quirk(&self, value: Quirk) -> Painted<&T>
fn quirk(&self, value: Quirk) -> Painted<&T>
Enables the yansi
[Quirk
] value
.
This method should be used rarely. Instead, prefer to use quirk-specific
builder methods like mask()
and
wrap()
, which have the same functionality but are
pithier.
§Example
Enable wrapping using .quirk()
:
use yansi::{Paint, Quirk};
painted.quirk(Quirk::Wrap);
Enable wrapping using wrap()
.
use yansi::Paint;
painted.wrap();
§fn clear(&self) -> Painted<&T>
👎Deprecated since 1.0.1: renamed to resetting()
due to conflicts with Vec::clear()
.
The clear()
method will be removed in a future release.
fn clear(&self) -> Painted<&T>
resetting()
due to conflicts with Vec::clear()
.
The clear()
method will be removed in a future release.§fn whenever(&self, value: Condition) -> Painted<&T>
fn whenever(&self, value: Condition) -> Painted<&T>
Conditionally enable styling based on whether the [Condition
] value
applies. Replaces any previous condition.
See the crate level docs for more details.
§Example
Enable styling painted
only when both stdout
and stderr
are TTYs:
use yansi::{Paint, Condition};
painted.red().on_yellow().whenever(Condition::STDOUTERR_ARE_TTY);
§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
self
and passes that borrow into the pipe function. Read more§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
self
and passes that borrow into the pipe function. Read more§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R,
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
self
, then passes self.as_ref()
into the pipe function.§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
self
, then passes self.as_mut()
into the pipe
function.§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
self
, then passes self.deref()
into the pipe function.§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
§impl<T> Tap for T
impl<T> Tap for T
§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Borrow<B>
of a value. Read more§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
BorrowMut<B>
of a value. Read more§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
AsRef<R>
view of a value. Read more§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
AsMut<R>
view of a value. Read more§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Deref::Target
of a value. Read more§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Deref::Target
of a value. Read more§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
.tap()
only in debug builds, and is erased in release builds.§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
.tap_mut()
only in debug builds, and is erased in release
builds.§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
.tap_borrow()
only in debug builds, and is erased in release
builds.§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
.tap_borrow_mut()
only in debug builds, and is erased in release
builds.§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
.tap_ref()
only in debug builds, and is erased in release
builds.§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
.tap_ref_mut()
only in debug builds, and is erased in release
builds.§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
.tap_deref()
only in debug builds, and is erased in release
builds.§impl<T> TryConv for T
impl<T> TryConv for T
§impl<T> WithSubscriber for T
impl<T> WithSubscriber for T
§fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘwhere
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘwhere
S: Into<Dispatch>,
§fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ
fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ
Source§impl<T> WithSubscriber for T
impl<T> WithSubscriber for T
Source§fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘwhere
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘwhere
S: Into<Dispatch>,
Source§fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ
fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ
impl<N, T> BlockReaderFor<N> for Twhere
N: NetworkPrimitives,
T: BlockReader<Block = <N as NetworkPrimitives>::Block, Header = <N as NetworkPrimitives>::BlockHeader, Transaction = <<N as NetworkPrimitives>::BlockBody as BlockBody>::Transaction, Receipt = <N as NetworkPrimitives>::Receipt>,
impl<T> ErasedDestructor for Twhere
T: 'static,
impl<T> MaybeDebug for Twhere
T: Debug,
impl<T> MaybeSend for Twhere
T: Send,
impl<T> MaybeSendSync for T
Layout§
Note: Unable to compute type layout, possibly due to this type having generic parameters. Layout can only be computed for concrete, fully-instantiated types.