Struct fuel_txpool::txpool::TxPool

pub struct TxPool { /* private fields */ }

Implementations

impl TxPool

pub fn new(config: Config) -> Self

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

pub fn dependency(&self) -> &Dependency

pub fn sorted_includable(&self) -> Vec<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 async fn insert(
    txpool: &RwLock<Self>,
    db: &dyn TxPoolDb,
    tx_status_sender: &TxStatusChange,
    txs: &[Arc<Transaction>]
) -> Vec<Result<InsertionResult>>

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

pub async fn find(txpool: &RwLock<Self>, hashes: &[TxId]) -> Vec<Option<TxInfo>>

find all tx by its hash

pub async fn find_one(txpool: &RwLock<Self>, hash: &TxId) -> Option<TxInfo>

pub async fn find_dependent(
    txpool: &RwLock<Self>,
    hashes: &[TxId]
) -> Vec<ArcPoolTx>

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

pub async fn filter_by_negative(
    txpool: &RwLock<Self>,
    tx_ids: &[TxId]
) -> Vec<TxId>

Iterate over hashes and return all hashes that we don’t have.

pub async fn pending_number(txpool: &RwLock<Self>) -> usize

The number of pending transaction in the pool.

pub async fn consumable_gas(txpool: &RwLock<Self>) -> u64

The amount of gas in all includable transactions combined

pub async fn includable(txpool: &RwLock<Self>) -> Vec<ArcPoolTx>

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

pub async fn block_update(
    txpool: &RwLock<Self>,
    tx_status_sender: &TxStatusChange,
    block: Arc<FuelBlock>
)

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

pub async fn remove(
    txpool: &RwLock<Self>,
    tx_status_sender: &TxStatusChange,
    tx_ids: &[TxId]
) -> Vec<ArcPoolTx>

remove transaction from pool needed on user demand. Low priority

Trait Implementations

impl Clone for TxPool

fn clone(&self) -> TxPool

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for TxPool

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

Formats the value using the given formatter.