Struct TxTracker 

pub struct TxTracker { /* private fields */ }

Core transaction tracker that monitors pending transactions.

Thread-safe via interior Mutex — suitable for shared access across Tokio tasks behind an Arc.

Implementations

impl TxTracker

pub fn new(config: TxTrackerConfig) -> Self

Create a new tracker with the given configuration.

pub fn track(&self, tx: TrackedTx)

Track a new pending transaction.

If the tracker is already at capacity (max_tracked), the transaction is silently dropped.

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

Remove a transaction from tracking.

pub fn update_status(&self, tx_hash: &str, status: TxStatus)

Update the status of a tracked transaction.

Does nothing if tx_hash is not currently tracked.

pub fn by_status(&self, status_match: &TxStatus) -> Vec<TrackedTx>

Get all transactions whose status matches status_match.

Comparison uses the discriminant only for variant-carrying statuses; for simple variants (Pending, Dropped) it uses PartialEq.

pub fn pending(&self) -> Vec<TrackedTx>

Get all pending transactions.

pub fn stuck(&self, current_time: u64) -> Vec<TrackedTx>

Get transactions that appear stuck (pending longer than stuck_timeout_secs).

pub fn next_nonce(&self, address: &str) -> Option<u64>

Get the next nonce for an address (local tracking).

Returns the stored nonce + 1, or None if the address has never been registered.

pub fn set_nonce(&self, address: &str, nonce: u64)

Set the nonce for an address (typically from an on-chain query).

pub fn count(&self) -> usize

Get count of tracked transactions.

pub fn get(&self, tx_hash: &str) -> Option<TrackedTx>

Get a snapshot of a specific transaction.