Struct node_bench::construct::Transactions

pub struct Transactions(Vec<Arc<PoolTransaction>>);

Tuple Fields

0: Vec<Arc<PoolTransaction>>

Trait Implementations

impl Clone for Transactions

fn clone(&self) -> Transactions

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Transactions

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

Formats the value using the given formatter.

impl TransactionPool for Transactions

fn submit_at<'life0, 'async_trait>( &'life0 self, _at: Self::Hash, _source: TransactionSource, _xts: Vec<TransactionFor<Self>>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Result<Hash, Self::Error>>, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Asynchronously imports a bunch of unverified transactions to the pool.

fn submit_one<'life0, 'async_trait>( &'life0 self, _at: Self::Hash, _source: TransactionSource, _xt: TransactionFor<Self>, ) -> Pin<Box<dyn Future<Output = Result<TxHash<Self>, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Asynchronously imports one unverified transaction to the pool.

type Block = Block<Header<u32, BlakeTwo256>, OpaqueExtrinsic>

Block type.

type Hash = H256

Transaction hash type.

type InPoolTransaction = PoolTransaction

In-pool transaction type.

type Error = Error

Error type.

fn submit_and_watch<'life0, 'async_trait>( &'life0 self, _at: Self::Hash, _source: TransactionSource, _xt: TransactionFor<Self>, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<TransactionStatusStreamFor<Self>>>, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Asynchronously imports a single transaction and starts to watch their progress in the pool.

fn ready_at<'life0, 'async_trait>( &'life0 self, _at: Self::Hash, ) -> Pin<Box<dyn Future<Output = Box<dyn ReadyTransactions<Item = Arc<Self::InPoolTransaction>> + Send>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get an iterator for ready transactions ordered by priority.

fn ready( &self, ) -> Box<dyn ReadyTransactions<Item = Arc<Self::InPoolTransaction>> + Send>

Get an iterator for ready transactions ordered by priority.

fn remove_invalid( &self, _hashes: &[TxHash<Self>], ) -> Vec<Arc<Self::InPoolTransaction>>

Remove transactions identified by given hashes (and dependent transactions) from the pool.

fn futures(&self) -> Vec<Self::InPoolTransaction>

Get futures transaction list.

fn status(&self) -> PoolStatus

Returns pool status.

fn import_notification_stream(&self) -> ImportNotificationStream<TxHash<Self>>

Return an event stream of transactions imported to the pool.

fn on_broadcasted(&self, _propagations: HashMap<TxHash<Self>, Vec<String>>)

Notify the pool about transactions broadcast.

fn hash_of(&self, _xt: &TransactionFor<Self>) -> TxHash<Self>

Returns transaction hash

fn ready_transaction( &self, _hash: &TxHash<Self>, ) -> Option<Arc<Self::InPoolTransaction>>

Return specific ready transaction by hash, if there is one.

fn ready_at_with_timeout<'life0, 'async_trait>( &'life0 self, _at: Self::Hash, _timeout: Duration, ) -> Pin<Box<dyn Future<Output = Box<dyn ReadyTransactions<Item = Arc<Self::InPoolTransaction>> + Send>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Asynchronously returns a set of ready transaction at given block within given timeout.