Struct Mempool 

pub struct Mempool { /* private fields */ }

Pending transaction pool

Implementations

impl Mempool

pub fn new(max_size: usize, min_fee: u64) -> Mempool

pub fn set_path(&self, path: &str)

pub fn load_from_file(&self, path: &str)

pub fn save_to_file(&self) -> Result<(), String>

pub fn is_modified(&self) -> bool

pub async fn submit( &self, tx: TransferTransaction, ledger: &RwLock<Ledger>, ) -> Result<[u8; 32], TxError>

Submit a transaction to the mempool after validation. Uses RwLock::read() for non-blocking reads since this is called from async context.

pub fn drain_for_block( &self, max_count: usize, min_fee: u64, ) -> Vec<TransferTransaction>

Drain highest-fee transactions for block inclusion

pub fn remove(&self, tx_hashes: &[[u8; 32]])

Remove confirmed transactions (after block acceptance)

pub fn revalidate(&self, ledger: &RwLock<Ledger>)

Revalidate all pending txs against current ledger state

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

pub fn hashes(&self) -> Vec<[u8; 32]>

pub fn get_tx(&self, hash: &[u8; 32]) -> Option<TransferTransaction>

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool