entropa-node 0.1.0

Entropa node — mempool, beacon-seeded proposer selection, and the consensus engine that produces and validates blocks. Networking (libp2p) layers on top of this.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

//! The mempool — pending transactions awaiting inclusion in a block.

use entropa_core::Transaction;

/// A FIFO pool of pending transactions.
#[derive(Debug, Default, Clone)]
pub struct Mempool {
    pending: Vec<Transaction>,
}

impl Mempool {
    pub fn new() -> Self {
        Self::default()
    }

    /// Submit a transaction into the pool.
    pub fn submit(&mut self, tx: Transaction) {
        self.pending.push(tx);
    }

    /// Remove and return up to `max` transactions, oldest first.
    pub fn drain(&mut self, max: usize) -> Vec<Transaction> {
        let n = max.min(self.pending.len());
        self.pending.drain(..n).collect()
    }

    pub fn pending(&self) -> &[Transaction] {
        &self.pending
    }

    pub fn len(&self) -> usize {
        self.pending.len()
    }

    pub fn is_empty(&self) -> bool {
        self.pending.is_empty()
    }
}