Struct reth_stages::test_utils::TestStageDB

pub struct TestStageDB {
    pub factory: ProviderFactory<MockNodeTypesWithDB>,
    pub temp_static_files_dir: TempDir,
}

Available on crate feature test-utils only.

Test database that is used for testing stage implementations.

Fields

factory: ProviderFactory<MockNodeTypesWithDB>

temp_static_files_dir: TempDir

Implementations

impl TestStageDB

pub fn new(path: &Path) -> Self

pub fn commit<F>(&self, f: F) -> ProviderResult<()>

where F: FnOnce(&<DatabaseEnv as Database>::TXMut) -> ProviderResult<()>,

Invoke a callback with transaction committing it afterwards

pub fn query<F, Ok>(&self, f: F) -> ProviderResult<Ok>

where F: FnOnce(&<DatabaseEnv as Database>::TX) -> ProviderResult<Ok>,

Invoke a callback with a read transaction

pub fn table_is_empty<T: Table>(&self) -> ProviderResult<bool>

Check if the table is empty

pub fn table<T: Table>(&self) -> ProviderResult<Vec<KeyValue<T>>>

where T::Key: Default + Ord,

Return full table as Vec

pub fn ensure_no_entry_above<T, F>( &self, num: u64, selector: F, ) -> ProviderResult<()>

where T: Table, F: FnMut(T::Key) -> BlockNumber,

Check that there is no table entry above a given number by [Table::Key]

pub fn ensure_no_entry_above_by_value<T, F>( &self, num: u64, selector: F, ) -> ProviderResult<()>

where T: Table, F: FnMut(T::Value) -> BlockNumber,

Check that there is no table entry above a given number by [Table::Value]

pub fn insert_header<TX: DbTx + DbTxMut>( writer: Option<&mut StaticFileProviderRWRefMut<'_>>, tx: &TX, header: &SealedHeader, td: U256, ) -> ProviderResult<()>

Insert header to static file if writer exists, otherwise to DB.

pub fn insert_headers<'a, I>(&self, headers: I) -> ProviderResult<()>

where I: IntoIterator<Item = &'a SealedHeader>,

Insert ordered collection of [SealedHeader] into the corresponding static file and tables that are supposed to be populated by the headers stage.

pub fn insert_headers_with_td<'a, I>(&self, headers: I) -> ProviderResult<()>

where I: IntoIterator<Item = &'a SealedHeader>,

Inserts total difficulty of headers into the corresponding static file and tables.

Superset functionality of TestStageDB::insert_headers.

pub fn insert_blocks<'a, I>( &self, blocks: I, storage_kind: StorageKind, ) -> ProviderResult<()>

where I: IntoIterator<Item = &'a SealedBlock>,

Insert ordered collection of SealedBlock into corresponding tables. Superset functionality of TestStageDB::insert_headers.

If tx_offset is set to None, then transactions will be stored on static files, otherwise database.

Assumes that there’s a single transition for each transaction (i.e. no block rewards).

pub fn insert_tx_hash_numbers<I>( &self, tx_hash_numbers: I, ) -> ProviderResult<()>

where I: IntoIterator<Item = (TxHash, TxNumber)>,

pub fn insert_receipts<I>(&self, receipts: I) -> ProviderResult<()>

where I: IntoIterator<Item = (TxNumber, Receipt)>,

Insert collection of ([TxNumber], Receipt) into the corresponding table.

pub fn insert_receipts_by_block<I, J>( &self, receipts: I, storage_kind: StorageKind, ) -> ProviderResult<()>

where I: IntoIterator<Item = (BlockNumber, J)>, J: IntoIterator<Item = (TxNumber, Receipt)>,

Insert collection of ([TxNumber], Receipt) organized by respective block numbers into the corresponding table or static file segment.

pub fn insert_transaction_senders<I>( &self, transaction_senders: I, ) -> ProviderResult<()>

where I: IntoIterator<Item = (TxNumber, Address)>,

pub fn insert_accounts_and_storages<I, S>( &self, accounts: I, ) -> ProviderResult<()>

where I: IntoIterator<Item = (Address, (Account, S))>, S: IntoIterator<Item = StorageEntry>,

Insert collection of ([Address], [Account]) into corresponding tables.

pub fn insert_changesets<I>( &self, changesets: I, block_offset: Option<u64>, ) -> ProviderResult<()>

where I: IntoIterator<Item = ChangeSet>,

Insert collection of [ChangeSet] into corresponding tables.

pub fn insert_history<I>( &self, changesets: I, _block_offset: Option<u64>, ) -> ProviderResult<()>

where I: IntoIterator<Item = ChangeSet>,

Trait Implementations

impl Debug for TestStageDB

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

Formats the value using the given formatter.

impl Default for TestStageDB

fn default() -> Self

Create a new instance of TestStageDB

Layout

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 152 bytes