Struct DBTransaction 

pub struct DBTransaction<'db, DB: DBAccess> { /* private fields */ }

Implementations

impl<DB: DBAccess> DBTransaction<'_, DB>

pub fn get_size(&self) -> usize

Trait Implementations

impl<DB: DBAccess> ConsensusStorage for DBTransaction<'_, DB>

Implementation of the Candidate trait for DBTransaction<'db, DB>.

fn store_candidate(&mut self, b: Block) -> Result<()>

Stores a candidate block in the database.

Arguments

• b - The block to store.

Returns

Returns Ok(()) if the block is successfully stored, or an error if the operation fails.

fn candidate(&self, hash: &[u8]) -> Result<Option<Block>>

Fetches a candidate block from the database.

Arguments

• hash - The hash of the block to fetch.

Returns

Returns Ok(Some(block)) if the block is found, Ok(None) if the block is not found, or an error if the operation fails.

fn delete_candidate<F>(&mut self, closure: F) -> Result<()>

where F: FnOnce(u64) -> bool + Copy,

Deletes candidate-related items from the database based on a closure.

Arguments

• closure - If the closure returns true, the block will be deleted.

Returns

Returns Ok(()) if the deletion is successful, or an error if the operation fails.

fn clear_candidates(&mut self) -> Result<()>

Deletes all items from the CF_CANDIDATES column family.

Returns

Returns Ok(()) if the deletion is successful, or an error if the operation fails.

fn store_validation_result( &mut self, consensus_header: &ConsensusHeader, validation_result: &ValidationResult, ) -> Result<()>

Stores a ValidationResult in the database.

Arguments

• vr - The ValidationResult to store.

Returns

Returns Ok(()) if the ValidationResult is successfully stored, or an error if the operation fails.

fn validation_result( &self, consensus_header: &ConsensusHeader, ) -> Result<Option<ValidationResult>>

Fetches a ValidationResult from the database.

Arguments

• consensus_header - The ConsensusHeader of the ValidationResult.

Returns

Returns Ok(Some(ValidationResult)) if the ValidationResult is found, Ok(None) if the ValidationResult is not found, or an error if the operation fails.

fn delete_validation_results<F>(&mut self, closure: F) -> Result<()>

where F: FnOnce([u8; 32]) -> bool + Copy,

Deletes ValidationResult items from the database based on a closure.

Arguments

• closure - If the closure returns true, the ValidationResult will be deleted.

Returns

Returns Ok(()) if the deletion is successful, or an error if the operation fails.

fn clear_validation_results(&mut self) -> Result<()>

Deletes all items from the CF_VALIDATION_RESULTS column family.

Returns

Returns Ok(()) if the deletion is successful, or an error if the operation fails.

fn candidate_by_iteration( &self, consensus_header: &ConsensusHeader, ) -> Result<Option<Block>>

Fetches a candidate block by lookup key (prev_block_hash, iteration).

fn count_candidates(&self) -> usize

fn count_validation_results(&self) -> usize

impl<DB: DBAccess> Debug for DBTransaction<'_, DB>

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

Formats the value using the given formatter.

impl<DB: DBAccess> Ledger for DBTransaction<'_, DB>

fn ledger_txs(&self, tx_ids: Vec<&[u8; 32]>) -> Result<Vec<SpentTransaction>>

Returns a list of transactions from the ledger

This function expects a list of transaction IDs that are in the ledger.

It will return an error if any of the transaction IDs are not found in the ledger.

fn ledger_tx_exists(&self, tx_id: &[u8]) -> Result<bool>

Returns true if the transaction exists in the ledger

This is a convenience method that checks if a transaction exists in the ledger without unmarshalling the transaction

fn store_block( &mut self, header: &Header, txs: &[SpentTransaction], faults: &[Fault], label: Label, ) -> Result<usize>

Read-write transactions Returns disk footprint of the committed transaction

fn faults_by_block(&self, start_height: u64) -> Result<Vec<Fault>>

fn store_block_label( &mut self, height: u64, hash: &[u8; 32], label: Label, ) -> Result<()>

fn delete_block(&mut self, b: &Block) -> Result<()>

fn block_exists(&self, hash: &[u8]) -> Result<bool>

fn faults(&self, faults_ids: &[[u8; 32]]) -> Result<Vec<Fault>>

fn latest_block(&self) -> Result<LightBlock>

fn blob_data_by_hash(&self, hash: &[u8; 32]) -> Result<Option<Vec<u8>>>

fn store_blob_data(&self, hash: &[u8; 32], data: Vec<u8>) -> Result<()>

fn store_blobs_height( &self, block_height: u64, blob_hashes: &[[u8; 32]], ) -> Result<()>

fn delete_blobs_by_height(&self, block_height: u64) -> Result<()>

fn blobs_by_height(&self, block_height: u64) -> Result<Option<Vec<[u8; 32]>>>

fn block(&self, hash: &[u8]) -> Result<Option<Block>>

fn light_block(&self, hash: &[u8]) -> Result<Option<LightBlock>>

fn block_header(&self, hash: &[u8]) -> Result<Option<Header>>

fn block_hash_by_height(&self, height: u64) -> Result<Option<[u8; 32]>>

fn ledger_tx(&self, tx_id: &[u8]) -> Result<Option<SpentTransaction>>

fn block_by_height(&self, height: u64) -> Result<Option<Block>>

fn block_label_by_height( &self, height: u64, ) -> Result<Option<([u8; 32], Label)>>

impl<DB: DBAccess> Mempool for DBTransaction<'_, DB>

fn mempool_expired_txs(&self, timestamp: u64) -> Result<Vec<[u8; 32]>>

Get all expired transactions hashes.

fn store_mempool_tx(&mut self, tx: &Transaction, timestamp: u64) -> Result<()>

Adds a transaction to the mempool with a timestamp.

fn mempool_tx(&self, hash: [u8; 32]) -> Result<Option<Transaction>>

Gets a transaction from the mempool.

fn mempool_tx_exists(&self, h: [u8; 32]) -> Result<bool>

Checks if a transaction exists in the mempool.

fn delete_mempool_tx( &mut self, h: [u8; 32], cascade: bool, ) -> Result<Vec<[u8; 32]>>

Deletes a transaction from the mempool.

fn mempool_txs_by_spendable_ids(&self, n: &[SpendingId]) -> HashSet<[u8; 32]>

Get transactions hash from the mempool, searching by spendable ids

fn mempool_txs_sorted_by_fee( &self, ) -> Box<dyn Iterator<Item = Transaction> + '_>

Get an iterator over the mempool transactions sorted by gas price

fn mempool_txs_ids_sorted_by_fee( &self, ) -> Box<dyn Iterator<Item = (u64, [u8; 32])> + '_>

Get an iterator over the mempool transactions hash by gas price

fn mempool_txs_ids_sorted_by_low_fee( &self, ) -> Box<dyn Iterator<Item = (u64, [u8; 32])> + '_>

Get an iterator over the mempool transactions hash by gas price (asc)

fn mempool_txs_ids(&self) -> Result<Vec<[u8; 32]>>

Get all transactions hashes.

fn mempool_txs_count(&self) -> usize

Number of persisted transactions

impl<DB: DBAccess> Metadata for DBTransaction<'_, DB>

fn op_write<T: AsRef<[u8]>>(&mut self, key: &[u8], value: T) -> Result<()>

Assigns an value to a key in the Metadata CF

fn op_read(&self, key: &[u8]) -> Result<Option<Vec<u8>>>

Reads an value of a key from the Metadata CF

impl<DB: DBAccess> Persist for DBTransaction<'_, DB>

fn clear_database(&mut self) -> Result<()>

Deletes all items from both CF_LEDGER and CF_CANDIDATES column families

fn commit(self) -> Result<()>

fn rollback(self) -> Result<()>