Struct Mempool 

pub struct Mempool { /* private fields */ }

Simple mempool: FIFO queue with deduplication

Implementations

impl Mempool

pub fn new(max_size: usize, max_tx_bytes: usize) -> Self

pub async fn add_tx(&self, tx: Vec<u8>) -> bool

Add a transaction to the mempool. Returns false if rejected.

pub async fn collect_payload(&self, max_bytes: usize) -> Vec<u8>

Collect transactions for a block proposal (up to max_bytes total). Collected transactions are removed from the pool. The payload is length-prefixed: [u32_le len][bytes]...

pub fn decode_payload(payload: &[u8]) -> Vec<Vec<u8>>

Reap collected payload back into individual transactions

pub async fn size(&self) -> usize

Trait Implementations

impl Default for Mempool

fn default() -> Self

Returns the “default value” for a type.