Struct fuel_core::service::adapters::TxPoolAdapter

pub struct TxPoolAdapter { /* private fields */ }

Implementations

impl TxPoolAdapter

pub fn new(service: TxPoolSharedState<P2PAdapter, Database>) -> Self

Trait Implementations

impl Clone for TxPoolAdapter

fn clone(&self) -> TxPoolAdapter

Returns a copy of the value.

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

Performs copy-assignment from source.

impl TransactionPool for TxPoolAdapter

fn pending_number(&self) -> usize

Returns the number of pending transactions in the TxPool.

fn total_consumable_gas(&self) -> u64

fn remove_txs(&self, ids: Vec<TxId>) -> Vec<ArcPoolTx>

fn transaction_status_events(&self) -> BoxStream<TxStatus>

impl TxPool for TxPoolAdapter

type TxSource = TransactionsSource

The source of the transactions used by the executor.

fn get_source(&self, block_height: BlockHeight) -> Self::TxSource

Returns the source of includable transactions.

impl TxPoolPort for TxPoolAdapter

fn transaction(&self, id: TxId) -> Option<Transaction>

fn submission_time(&self, id: TxId) -> Option<Tai64>

fn insert(&self, txs: Vec<Arc<Transaction>>) -> Vec<Result<InsertionResult>>

fn tx_update_subscribe( &self ) -> BoxStream<Result<TxUpdate, BroadcastStreamRecvError>>