Struct MemPool 

pub struct MemPool { /* private fields */ }

Implementations

impl MemPool

pub fn new() -> Self

pub fn start_expiry_watchdog( &self, on_expiry: impl FnMut(TransactionId) + Send + Sync + 'static, )

Starts a background task that removes expired transactions

pub async fn get_mempool(&self) -> Vec<Transaction>

Get a vector of all transactions in this mempool

pub async fn add_transaction(&self, transaction: Transaction)

Add a transaction to the mempool WARNING: Make sure this transaction is valid before

pub async fn validate_transaction(&self, transaction: &Transaction) -> bool

Returns true if a transaction is valid (check for double spending)

pub async fn spend_transactions(&self, transactions: Vec<TransactionId>)

Remove transactions that have been spent

pub async fn mempool_size(&self) -> usize

pub async fn clear(&self)