Struct PosLedgerDB 

pub struct PosLedgerDB { /* private fields */ }

This holds a handle to the underlying DB responsible for physical storage and provides APIs for access to the core Diem data structures.

Implementations

impl PosLedgerDB

pub fn open<P: AsRef<Path> + Clone>( db_root_path: P, readonly: bool, rocksdb_config: RocksdbConfig, ) -> Result<Self>

pub fn get_transaction(&self, version: Version) -> Result<Transaction>

pub fn get_transaction_block_meta( &self, version: Version, ) -> Result<Option<(Version, BlockMetadata)>>

pub fn get_transaction_info(&self, version: u64) -> Result<TransactionInfo>

Trait Implementations

impl DBReaderForPoW for PosLedgerDB

fn get_latest_ledger_info_option(&self) -> Option<LedgerInfoWithSignatures>

fn get_block_ledger_info( &self, consensus_block_id: &HashValue, ) -> Result<LedgerInfoWithSignatures>

TODO(lpl): It’s possible to use round number?

fn get_events_by_version( &self, start_version: u64, end_version: u64, ) -> Result<Vec<ContractEvent>>

fn get_epoch_ending_blocks( &self, start_epoch: u64, end_epoch: u64, ) -> Result<Vec<HashValue>>

fn get_reward_event(&self, epoch: u64) -> Result<RewardDistributionEventV2>

fn get_committed_block_by_hash( &self, block_hash: &HashValue, ) -> Result<CommittedBlock>

fn get_committed_block_hash_by_view(&self, view: u64) -> Result<HashValue>

fn get_ledger_info_by_voted_block( &self, block_id: &HashValue, ) -> Result<LedgerInfoWithSignatures>

fn get_block_hash_by_epoch_and_round( &self, epoch: u64, round: u64, ) -> Result<HashValue>

impl DbReader for PosLedgerDB

fn get_epoch_ending_ledger_info( &self, version: u64, ) -> Result<LedgerInfoWithSignatures>

Gets ledger info at specified version and ensures it’s an epoch ending.

fn get_epoch_ending_ledger_infos( &self, start_epoch: u64, end_epoch: u64, ) -> Result<EpochChangeProof>

See DiemDB::get_epoch_ending_ledger_infos.

fn get_block_timestamp(&self, version: u64) -> Result<u64>

See DiemDB::get_block_timestamp.

fn get_latest_ledger_info(&self) -> Result<LedgerInfoWithSignatures>

Returns the latest ledger info.

fn get_startup_info(&self, need_pos_state: bool) -> Result<Option<StartupInfo>>

Gets information needed from storage during the main node startup. See DiemDB::get_startup_info.

fn get_latest_tree_state(&self) -> Result<TreeState>

Gets the latest TreeState no matter if db has been bootstrapped. Used by the Db-bootstrapper.

fn get_latest_transaction_info_option( &self, ) -> Result<Option<(Version, TransactionInfo)>>

Gets the latest transaction info. N.B. Unlike get_startup_info(), even if the db is not bootstrapped, this can return Some – those from a db-restore run.

fn get_pos_state(&self, block_id: &HashValue) -> Result<PosState>

fn get_latest_pos_state(&self) -> Arc<PosState>

fn get_latest_version(&self) -> Result<u64, Error>

Returns the latest ledger info.

fn get_latest_commit_metadata(&self) -> Result<(u64, u64), Error>

Returns the latest version and committed block timestamp

impl DbWriter for PosLedgerDB

fn save_transactions( &self, txns_to_commit: &[TransactionToCommit], first_version: Version, ledger_info_with_sigs: Option<&LedgerInfoWithSignatures>, pos_state: Option<PosState>, committed_blocks: Vec<CommittedBlock>, ledger_infos_with_voted_block: Vec<(HashValue, LedgerInfoWithSignatures)>, ) -> Result<()>

first_version is the version of the first transaction in txns_to_commit. When ledger_info_with_sigs is provided, verify that the transaction accumulator root hash it carries is generated after the txns_to_commit are applied. Note that even if txns_to_commit is empty, frist_version is checked to be ledger_info_with_sigs.ledger_info.version + 1 if ledger_info_with_sigs is not None.

fn save_reward_event( &self, epoch: u64, event: &RewardDistributionEventV2, ) -> Result<()>

fn delete_pos_state_by_block(&self, block_id: &HashValue) -> Result<()>

impl Debug for PosLedgerDB

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

Formats the value using the given formatter.