Struct InMemoryMempool 

pub struct InMemoryMempool { /* private fields */ }

In-memory mempool implementation with fee-rate ordering and eviction.

All mutable state is held behind a single RwLock<MempoolInner> to eliminate the deadlock risk from acquiring multiple independent locks (code review finding #17).

Implementations

impl InMemoryMempool

pub fn new() -> Self

Create a new in-memory mempool with default settings

pub fn with_max_bytes(max_bytes: u64) -> Self

Create a new in-memory mempool with custom max size

pub async fn set_height(&self, height: u32)

Set the current chain height

pub async fn size(&self) -> usize

Get the number of transactions in the mempool

pub async fn get_transactions_by_fee_rate( &self, max_weight: u32, ) -> Vec<MempoolEntry>

Get transactions ordered by ancestor fee rate (CPFP-aware) for mining.

pub async fn remove_for_block(&self, transactions: &[Transaction])

Remove transactions that were confirmed in a block

Trait Implementations

impl Default for InMemoryMempool

fn default() -> Self

Returns the “default value” for a type.

impl MempoolPort for InMemoryMempool

fn add_transaction<'life0, 'life1, 'async_trait>( &'life0 self, tx: &'life1 Transaction, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

Adds a transaction to the mempool.

fn remove_transaction<'life0, 'life1, 'async_trait>( &'life0 self, txid: &'life1 Txid, recursive: bool, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

Removes a transaction from the mempool.

fn get_transaction<'life0, 'life1, 'async_trait>( &'life0 self, txid: &'life1 Txid, ) -> Pin<Box<dyn Future<Output = Result<Option<MempoolEntry>, Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

Retrieves a transaction from the mempool.

fn get_all_transactions<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<MempoolEntry>, Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

Retrieves all transactions in the mempool.

fn get_transaction_count<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<u32, Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

Gets the number of transactions in the mempool.

fn estimate_fee<'life0, 'async_trait>( &'life0 self, target_blocks: u32, ) -> Pin<Box<dyn Future<Output = Result<f64, Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

Estimates the fee rate needed to confirm within target blocks.

fn get_mempool_info<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<MempoolInfo, Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

Gets summary information about the mempool.

fn clear<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

Clears the entire mempool.