Struct PendingPoolMonitor 

pub struct PendingPoolMonitor { /* private fields */ }

Monitors pending transactions and reports status changes.

The monitor maintains a thread-safe set of transaction hashes and provides a static check_status method to query a transport for the current state of a transaction.

Implementations

impl PendingPoolMonitor

pub fn new(config: PendingPoolConfig) -> Self

Create a new monitor with the given configuration.

pub fn watch(&self, tx_hash: String) -> bool

Add a transaction hash to monitor.

Returns true if the hash was added, false if already present or if the monitor is at maximum capacity.

pub fn unwatch(&self, tx_hash: &str)

Remove a transaction from monitoring.

pub fn watched(&self) -> Vec<String>

Get all currently watched transaction hashes.

pub fn count(&self) -> usize

Number of transactions being monitored.

pub fn poll_interval_ms(&self) -> u64

Get the poll interval from the config.

pub async fn check_status( transport: &dyn RpcTransport, tx_hash: &str, ) -> Result<PendingTxStatus, TransportError>

Check the status of a single tx by querying the transport.

Calls eth_getTransactionReceipt on the transport:

• If the receipt exists and contains a blockNumber, the tx is Included.
• If the receipt is null we fall back to eth_getTransactionByHash:
  • If the tx object is present the tx is still Pending.
  • Otherwise it is NotFound.