Struct fuel_core_txpool::txpool::TxPool

pub struct TxPool<DB> { /* private fields */ }

Implementations

impl<DB> TxPool<DB>where DB: TxPoolDb,

pub fn new(config: Config, database: DB) -> Self

pub fn txs(&self) -> &HashMap<TxId, TxInfo>

pub fn dependency(&self) -> &Dependency

pub fn sorted_includable(&self) -> impl Iterator<Item = ArcPoolTx> + '_

Return all sorted transactions that are includable in next block.

pub fn remove_inner(&mut self, tx: &ArcPoolTx) -> Vec<ArcPoolTx>

pub fn remove_by_tx_id(&mut self, tx_id: &TxId) -> Vec<ArcPoolTx>

remove transaction from pool needed on user demand. Low priority

pub fn remove_committed_tx(&mut self, tx_id: &TxId) -> Vec<ArcPoolTx>

Removes transaction from TxPool with assumption that it is committed into the blockchain.

pub fn insert( &mut self, tx_status_sender: &TxStatusChange, txs: &[Arc<Transaction>] ) -> Vec<Result<InsertionResult>>

Import a set of transactions from network gossip or GraphQL endpoints.

pub fn find(&self, hashes: &[TxId]) -> Vec<Option<TxInfo>>

find all tx by its hash

pub fn find_one(&self, hash: &TxId) -> Option<TxInfo>

pub fn find_dependent(&self, hashes: &[TxId]) -> Vec<ArcPoolTx>

find all dependent tx and return them with requested dependencies in one list sorted by Price.

pub fn pending_number(&self) -> usize

The number of pending transaction in the pool.

pub fn consumable_gas(&self) -> u64

The amount of gas in all includable transactions combined

pub fn includable(&mut self) -> impl Iterator<Item = ArcPoolTx> + '_

Return all sorted transactions that are includable in next block. This is going to be heavy operation, use it only when needed.

pub fn block_update( &mut self, tx_status_sender: &TxStatusChange, transactions: &[TxId] )

When block is updated we need to receive all spend outputs and remove them from txpool.

pub fn remove( &mut self, tx_status_sender: &TxStatusChange, tx_ids: &[TxId] ) -> Vec<ArcPoolTx>

remove transaction from pool needed on user demand. Low priority

pub fn prune_old_txs(&mut self) -> Vec<ArcPoolTx>

Remove all old transactions from the pool.

Trait Implementations

impl<DB: Clone> Clone for TxPool<DB>

fn clone(&self) -> TxPool<DB>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<DB: Debug> Debug for TxPool<DB>

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

Formats the value using the given formatter.