Struct RocksStorageState

pub struct RocksStorageState {
    pub db: Arc<DB>,
    pub transactions: RocksCfRef<'static, HashRocksdb, CfTransactionsValue>,
    pub blocks_by_number: RocksCfRef<'static, BlockNumberRocksdb, CfBlocksByNumberValue>,
    /* private fields */
}

State handler for our RocksDB storage, separating “tables” by column families.

With data separated by column families, writing and reading should be done via the RocksCfRef fields.

Fields

db: Arc<DB>

transactions: RocksCfRef<'static, HashRocksdb, CfTransactionsValue>

blocks_by_number: RocksCfRef<'static, BlockNumberRocksdb, CfBlocksByNumberValue>

Implementations

impl RocksStorageState

pub fn new( path: String, shutdown_timeout: Duration, cache_multiplier: Option<f32>, enable_sync_write: bool, ) -> Result<Self>

pub fn preload_block_number(&self) -> Result<AtomicU32>

pub fn read_transaction( &self, tx_hash: Hash, ) -> Result<Option<TransactionMined>>

pub fn read_logs(&self, filter: &LogFilter) -> Result<Vec<LogMined>>

pub fn read_slot( &self, address: Address, index: SlotIndex, point_in_time: PointInTime, ) -> Result<Option<Slot>>

pub fn read_account( &self, address: Address, point_in_time: PointInTime, ) -> Result<Option<Account>>

pub fn read_block(&self, selection: BlockFilter) -> Result<Option<Block>>

pub fn save_accounts(&self, accounts: Vec<Account>) -> Result<()>

pub fn save_genesis_block( &self, block: Block, accounts: Vec<Account>, account_changes: ExecutionChanges, ) -> Result<()>

pub fn save_block( &self, block: Block, account_changes: ExecutionChanges, ) -> Result<()>

pub fn prepare_block_insertion( &self, block: Block, account_changes: ExecutionChanges, batch: &mut WriteBatch, ) -> Result<()>

pub fn write_in_batch_for_multiple_cfs(&self, batch: WriteBatch) -> Result<()>

Write to DB in a batch

pub fn read_block_with_changes( &self, selection: BlockFilter, ) -> Result<Option<(Block, ExecutionChanges)>>

impl RocksStorageState

pub fn export_column_family_size_metrics(&self) -> Result<()>

Trait Implementations

impl Debug for RocksStorageState

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

Formats the value using the given formatter.

impl Drop for RocksStorageState

fn drop(&mut self)

Executes the destructor for this type.