Struct TransactionsHandle

pub struct TransactionsHandle<N = EthNetworkPrimitives>
where
    N: NetworkPrimitives,
{ /* private fields */ }

Api to interact with TransactionsManager task.

This can be obtained via TransactionsManager::handle and can be used to manually interact with the TransactionsManager task once it is spawned.

For example TransactionsHandle::get_peer_transaction_hashes returns the transaction hashes known by a specific peer.

Implementations

impl<N> TransactionsHandle<N>

where N: NetworkPrimitives,

Implementation of the TransactionsHandle API for use in testnet via type PeerHandle.

pub fn propagate(&self, hash: FixedBytes<32>)

Manually propagate the transaction that belongs to the hash.

pub fn propagate_hash_to(&self, hash: FixedBytes<32>, peer: FixedBytes<64>)

Manually propagate the transaction hash to a specific peer.

Note: this only propagates if the pool contains the transaction.

pub fn propagate_hashes_to( &self, hash: impl IntoIterator<Item = FixedBytes<32>>, peer: FixedBytes<64>, )

Manually propagate the transaction hashes to a specific peer.

Note: this only propagates the transactions that are known to the pool.

pub async fn get_active_peers( &self, ) -> Result<HashSet<FixedBytes<64>>, RecvError>

Request the active peer IDs from the TransactionsManager.

pub fn propagate_transactions_to( &self, transactions: Vec<FixedBytes<32>>, peer: FixedBytes<64>, )

Manually propagate full transaction hashes to a specific peer.

Do nothing if transactions are empty.

pub fn propagate_transactions(&self, transactions: Vec<FixedBytes<32>>)

Manually propagate the given transaction hashes to all peers.

It’s up to the TransactionsManager whether the transactions are sent as hashes or in full.

pub fn broadcast_transactions( &self, transactions: impl IntoIterator<Item = <N as NetworkPrimitives>::BroadcastedTransaction>, )

Manually propagate the given transactions to all peers.

It’s up to the TransactionsManager whether the transactions are sent as hashes or in full.

pub async fn get_transaction_hashes( &self, peers: Vec<FixedBytes<64>>, ) -> Result<HashMap<FixedBytes<64>, HashSet<FixedBytes<32>>>, RecvError>

Request the transaction hashes known by specific peers.

pub async fn get_peer_transaction_hashes( &self, peer: FixedBytes<64>, ) -> Result<HashSet<FixedBytes<32>>, RecvError>

Request the transaction hashes known by a specific peer.

pub async fn get_pooled_transactions_from( &self, peer_id: FixedBytes<64>, hashes: Vec<FixedBytes<32>>, ) -> Result<Option<Vec<<N as NetworkPrimitives>::PooledTransaction>>, RequestError>

Requests the transactions directly from the given peer.

Returns None if the peer is not connected.

Note: this returns the response from the peer as received.

Trait Implementations

impl<N> Clone for TransactionsHandle<N>

where N: Clone + NetworkPrimitives,

fn clone(&self) -> TransactionsHandle<N>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<N> Debug for TransactionsHandle<N>

where N: Debug + NetworkPrimitives,

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

Formats the value using the given formatter.

Layout

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 8 bytes