Struct RocksStorageState

pub struct RocksStorageState {
    pub db: Arc<DB>,
    pub transactions: RocksCfRef<'static, HashRocksdb, CfTransactionsValue>,
    pub blocks_by_number: RocksCfRef<'static, BlockNumberRocksdb, CfBlocksByNumberValue>,
    pub use_rocksdb_replication: bool,
    /* 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>

use_rocksdb_replication: bool

Implementations

impl RocksStorageState

pub fn new( path: String, shutdown_timeout: Duration, cache_multiplier: Option<f32>, enable_sync_write: bool, use_rocksdb_replication: 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 read_replication_log( &self, block_number: BlockNumber, ) -> Result<Option<WriteBatch>>

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

pub fn save_block_batch(&self, block_batch: Vec<Block>) -> Result<()>

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

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

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

pub fn apply_replication_log( &self, block_number: BlockNumber, replication_log: WriteBatch, ) -> Result<()>

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

Write to DB in a batch

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.