Struct snarkos_consensus::memory_pool::MemoryPool

pub struct MemoryPool<T: Transaction> {
    pub transactions: HashMap<Vec<u8>, Entry<T>>,
    pub total_size_in_bytes: usize,
}

Stores transactions received by the server. Transaction entries will eventually be fetched by the miner and assembled into blocks.

Fields

transactions: HashMap<Vec<u8>, Entry<T>>

The mapping of all unconfirmed transaction IDs to their corresponding transaction data.

total_size_in_bytes: usize

The total size in bytes of the current memory pool.

Implementations

impl<T: Transaction> MemoryPool<T>

pub fn new() -> Self

Initialize a new memory pool with no transactions

pub fn from_storage<P: LoadableMerkleParameters>(
    storage: &Ledger<T, P>
) -> Result<Self, ConsensusError>

Load the memory pool from previously stored state in storage

pub fn store<P: LoadableMerkleParameters>(
    &self,
    storage: &Ledger<T, P>
) -> Result<(), ConsensusError>

Store the memory pool state to the database

pub fn insert<P: LoadableMerkleParameters>(
    &mut self,
    storage: &Ledger<T, P>,
    entry: Entry<T>
) -> Result<Option<Vec<u8>>, ConsensusError>

Adds entry to memory pool if valid in the current ledger.

pub fn cleanse<P: LoadableMerkleParameters>(
    &mut self,
    storage: &Ledger<T, P>
) -> Result<(), ConsensusError>

Cleanse the memory pool of outdated transactions.

pub fn remove(
    &mut self,
    entry: &Entry<T>
) -> Result<Option<Vec<u8>>, ConsensusError>

Removes transaction from memory pool or error.

pub fn remove_by_hash(
    &mut self,
    transaction_id: &[u8]
) -> Result<Option<Entry<T>>, ConsensusError>

Removes transaction from memory pool based on the transaction id.

pub fn contains(&self, entry: &Entry<T>) -> bool

Returns whether or not the memory pool contains the entry.

pub fn get_candidates<P: LoadableMerkleParameters>(
    &self,
    storage: &Ledger<T, P>,
    max_size: usize
) -> Result<DPCTransactions<T>, ConsensusError>

Get candidate transactions for a new block.

Trait Implementations

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

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug + Transaction> Debug for MemoryPool<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: Transaction> Default for MemoryPool<T>

fn default() -> Self

Returns the “default value” for a type.