Struct KabuDB

pub struct KabuDB
where
    Self: Sized + Send + Sync,
{
    pub accounts: HashMap<Address, FastDbAccount>,
    pub contracts: HashMap<B256, Bytecode, SimpleBuildHasher>,
    pub logs: Vec<Log>,
    pub block_hashes: HashMap<BlockNumber, B256>,
    pub read_only_db: Option<Arc<KabuDB>>,
    pub ext_db: Option<Arc<dyn DatabaseRef<Error = KabuDBError> + Send + Sync>>,
}

Fields

accounts: HashMap<Address, FastDbAccount>

contracts: HashMap<B256, Bytecode, SimpleBuildHasher>

logs: Vec<Log>

block_hashes: HashMap<BlockNumber, B256>

read_only_db: Option<Arc<KabuDB>>

ext_db: Option<Arc<dyn DatabaseRef<Error = KabuDBError> + Send + Sync>>

Implementations

impl KabuDB

pub fn empty() -> Self

pub fn new() -> Self

pub fn is_rw_ro_account(&self, address: &Address) -> bool

pub fn is_rw_ro_slot(&self, address: &Address, slot: &U256) -> bool

pub fn read_only_db(&self) -> Self

pub fn rw_contracts_len(&self) -> usize

pub fn rw_accounts_len(&self) -> usize

pub fn ro_contracts_len(&self) -> usize

pub fn ro_accounts_len(&self) -> usize

pub fn rw_storage_len(&self) -> usize

pub fn ro_storage_len(&self) -> usize

pub fn with_ext_db<ExtDB>(self, ext_db: ExtDB) -> Self

where ExtDB: DatabaseRef<Error = KabuDBError> + Send + Sync + 'static, Self: Sized,

pub fn without_ext_db(self) -> Self

where Self: Sized,

pub fn with_ro_db(self, db: Option<KabuDB>) -> Self

pub fn new_with_ext_db<ExtDB>(db: KabuDB, ext_db: ExtDB) -> Self

where ExtDB: DatabaseRef<Error = KabuDBError> + Send + Sync + 'static, Self: Sized,

pub fn load_ro_rw_ext_account( &mut self, address: Address, ) -> Result<&mut FastDbAccount>

If the account was not found in the cache, it will be loaded from the underlying database.

pub fn load_ro_rw_account( &mut self, address: Address, ) -> Result<&mut FastDbAccount>

If the account was not found in the cache, it will be loaded from the underlying database.

pub fn new_with_ro_db_and_provider<P, N>( read_only_db: Option<KabuDB>, client: P, ) -> Result<Self>

where N: Network, P: Provider<N> + 'static, Self: Sized,

pub fn insert_contract(&mut self, account: &mut AccountInfo)

pub fn insert_account_info(&mut self, address: Address, info: AccountInfo)

Insert account info but not override storage

pub fn insert_account_storage( &mut self, address: Address, slot: U256, value: U256, ) -> Result<()>

insert account storage without overriding account info

pub fn replace_account_storage( &mut self, address: Address, storage: HashMap<U256, U256>, ) -> Result<()>

replace account storage without overriding account info

pub fn merge_all(self) -> KabuDB

pub fn merge_accounts(self) -> KabuDB

pub fn merge_cells(self) -> KabuDB

pub fn apply_geth_update(&mut self, update: BTreeMap<Address, GethAccountState>)

pub fn apply_geth_update_vec( &mut self, update: Vec<BTreeMap<Address, GethAccountState>>, )

pub fn apply_account_info_btree( &mut self, address: &Address, account_updated_state: &AccountState, insert: bool, only_new: bool, )

pub fn apply_account_storage( &mut self, address: &Address, acc_state: &GethAccountState, insert: bool, only_new: bool, )

pub fn apply_geth_state_update( &mut self, update_vec: &Vec<BTreeMap<Address, GethAccountState>>, insert: bool, only_new: bool, ) -> &mut Self

Trait Implementations

impl Clone for KabuDB

where Self: Sized + Send + Sync,

fn clone(&self) -> KabuDB

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Database for KabuDB

fn storage(&mut self, address: Address, slot: U256) -> Result<U256, Self::Error>

Get the value in an account’s storage slot.

It is assumed that account is already loaded.

type Error = KabuDBError

The database error type.

fn basic( &mut self, address: Address, ) -> Result<Option<AccountInfo>, Self::Error>

Gets basic account information.

fn code_by_hash(&mut self, code_hash: B256) -> Result<Bytecode, Self::Error>

Gets account code by its hash.

fn block_hash(&mut self, number: BlockNumber) -> Result<B256, Self::Error>

Gets block hash by block number.

impl DatabaseCommit for KabuDB

fn commit(&mut self, changes: HashMap<Address, Account>)

Commit changes to the database.

impl DatabaseKabuExt for KabuDB

fn with_ext_db( &mut self, arc_db: impl DatabaseRef<Error = KabuDBError> + Send + Sync + 'static, )

fn is_account(&self, address: &Address) -> bool

fn is_slot(&self, address: &Address, slot: &U256) -> bool

fn contracts_len(&self) -> usize

fn accounts_len(&self) -> usize

fn storage_len(&self) -> usize

fn load_account(&mut self, address: Address) -> Result<&mut FastDbAccount>

fn load_cached_account( &mut self, address: Address, ) -> Result<&mut FastDbAccount>

fn insert_contract(&mut self, account: &mut AccountInfo)

fn insert_account_info(&mut self, address: Address, info: AccountInfo)

fn insert_account_storage( &mut self, address: Address, slot: U256, value: U256, ) -> Result<()>

fn replace_account_storage( &mut self, address: Address, storage: HashMap<U256, U256>, ) -> Result<()>

fn maintain(self) -> Self

impl DatabaseRef for KabuDB

type Error = KabuDBError

The database error type.

fn basic_ref( &self, address: Address, ) -> Result<Option<AccountInfo>, Self::Error>

Gets basic account information.

fn code_by_hash_ref(&self, code_hash: B256) -> Result<Bytecode, Self::Error>

Gets account code by its hash.

fn storage_ref(&self, address: Address, slot: U256) -> Result<U256, Self::Error>

Gets storage value of address at index.

fn block_hash_ref(&self, number: BlockNumber) -> Result<B256, Self::Error>

Gets block hash by block number.

impl Debug for KabuDB

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

Formats the value using the given formatter.

impl Default for KabuDB

fn default() -> Self

Returns the “default value” for a type.

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: 160 bytes