Struct MempoolListener 

pub struct MempoolListener { /* private fields */ }

Listener for monitoring mempool transactions

Implementations

impl MempoolListener

pub fn new(evm: Arc<Evm>) -> Self

Creates a new MempoolListener with default configuration

pub fn with_config(evm: Arc<Evm>, config: MempoolConfig) -> Self

Creates a new MempoolListener with custom configuration

pub async fn start(&self) -> Result<(), EvmError>

Starts the mempool listener

Example

let evm = Arc::new(Evm::new());
let listener = MempoolListener::new(evm);
listener.start().await?;

pub async fn stop(&self)

Stops the mempool listener

pub async fn get_pending_transactions_list(&self) -> Vec<MempoolTransaction>

Returns all pending transactions in the mempool

Example

let transactions = listener.get_pending_transactions_list().await;
for tx in transactions {
    println!("Transaction hash: {:?}", tx.hash);
}

pub async fn get_transactions_by_sender( &self, address: Address, ) -> Vec<MempoolTransaction>

Returns pending transactions sent by a specific address

Example

let address: Address = "0x...".parse().unwrap();
let sender_txs = listener.get_transactions_by_sender(address).await;

pub async fn get_transactions_by_receiver( &self, address: Address, ) -> Vec<MempoolTransaction>

Returns pending transactions sent to a specific address

Example

let address: Address = "0x...".parse().unwrap();
let receiver_txs = listener.get_transactions_by_receiver(address).await;

pub async fn get_high_gas_transactions( &self, threshold: U256, ) -> Vec<MempoolTransaction>

Returns transactions with gas price above the specified threshold

Example

let threshold = U256::from(100_000_000_000u64); // 100 Gwei
let high_gas_txs = listener.get_high_gas_transactions(threshold).await;

pub async fn get_large_value_transactions( &self, threshold: U256, ) -> Vec<MempoolTransaction>

Returns transactions with value above the specified threshold

Example

let threshold = U256::from(1_000_000_000_000_000_000u64); // 1 ETH
let large_txs = listener.get_large_value_transactions(threshold).await;

pub async fn get_stats(&self) -> MempoolStats

Returns statistics about the current mempool state

Example

let stats = listener.get_stats().await;
println!("Total transactions: {}", stats.total_transactions);
println!("Total value: {}", stats.total_value);

pub async fn contains_transaction(&self, tx_hash: TxHash) -> bool

Checks if a specific transaction is in the mempool

Example

let tx_hash: TxHash = "0x...".parse().unwrap();
if listener.contains_transaction(tx_hash).await {
    println!("Transaction is pending");
}

pub async fn get_transaction_details( &self, tx_hash: TxHash, ) -> Option<MempoolTransaction>

Returns details for a specific transaction

Example

let tx_hash: TxHash = "0x...".parse().unwrap();
if let Some(tx) = listener.get_transaction_details(tx_hash).await {
    println!("From: {:?}, To: {:?}, Value: {}", tx.from, tx.to, tx.value);
}

pub async fn get_eip1559_transactions(&self) -> Vec<MempoolTransaction>

get eip1559 transactions

pub async fn get_mev_transactions(&self) -> Vec<MempoolTransaction>

get mev transactions

pub async fn get_bundle_transactions( &self, bundle_hash: TxHash, ) -> Vec<MempoolTransaction>

pub async fn get_all_bundles(&self) -> HashMap<TxHash, Vec<TxHash>>

Trait Implementations

impl Clone for MempoolListener

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.