Struct MemoryPool 

pub struct MemoryPool<T> { /* private fields */ }

Implementation of Mempool effects using pure_stage::Effects.

It supports operations

• for the tx submission protocol
• for transaction validation

Implementations

impl<T> MemoryPool<T>

pub fn new(effects: Effects<T>) -> MemoryPool<T>

pub fn external_sync<E: ExternalEffectSync + Serialize + 'static>( &self, effect: E, ) -> E::Response

where T: SendData + Sync,

This function runs an external effect synchronously.

Trait Implementations

impl<T: SendData + Sync> CanValidateTransactions<Transaction> for MemoryPool<T>

fn validate_transaction( &self, tx: Transaction, ) -> Result<(), TransactionValidationError>

This effect uses the ledger to validate a transaction before adding it to the mempool.

impl<T: Clone> Clone for MemoryPool<T>

fn clone(&self) -> MemoryPool<T>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: SendData + Sync> TxSubmissionMempool<Transaction> for MemoryPool<T>

fn insert( &self, tx: Transaction, tx_origin: TxOrigin, ) -> Result<(TxId, MempoolSeqNo), TxRejectReason>

This effect inserts a transaction into the mempool, specifying its origin. A TxOrigin::Local origin indicates the transaction was created on the current node, A TxOrigin::Remote(origin_peer) indicates the transaction was received from a remote peer

fn get_tx(&self, tx_id: &TxId) -> Option<Transaction>

This effect retrieves a transaction by its id. It returns None if the transaction is not found.

fn tx_ids_since( &self, from_seq: MempoolSeqNo, limit: u16, ) -> Vec<(TxId, u32, MempoolSeqNo)>

This effect retrieves a list of transaction ids from a given sequence number (inclusive), up to a given limit.

fn wait_for_at_least( &self, seq_no: MempoolSeqNo, ) -> Pin<Box<dyn Future<Output = bool> + Send + '_>>

This effect waits until the mempool reaches at least the given sequence number.

fn get_txs_for_ids(&self, ids: &[TxId]) -> Vec<Transaction>

This effect retrieves a list of transactions for the given ids.

fn last_seq_no(&self) -> MempoolSeqNo

This effect gets the last assigned sequence number in the mempool.

fn add(&self, tx: Tx) -> Result<(), TxRejectReason>

Add a new, local, transaction to the mempool.

fn contains(&self, tx_id: &TxId) -> bool

Return true if the mempool contains a transaction with the given id.