fuel-core-txpool 0.17.5

Transaction pool
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
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

use crate::{
    types::*,
    TxInfo,
};
use fuel_core_types::services::txpool::ArcPoolTx;
use std::collections::BTreeMap;

#[derive(Debug, Clone)]
pub struct Sort<Key> {
    /// all transactions sorted by min/max value
    pub sort: BTreeMap<Key, ArcPoolTx>,
}

impl<Key> Default for Sort<Key> {
    fn default() -> Self {
        Self {
            sort: Default::default(),
        }
    }
}

impl<Key> Sort<Key>
where
    Key: SortableKey,
{
    pub fn remove(&mut self, info: &TxInfo) {
        self.sort.remove(&Key::new(info));
    }

    pub fn lowest_tx(&self) -> Option<ArcPoolTx> {
        self.sort.iter().next().map(|(_, tx)| tx.clone())
    }

    pub fn lowest_value(&self) -> Option<Key::Value> {
        self.sort.iter().next().map(|(key, _)| key.value().clone())
    }

    pub fn lowest(&self) -> Option<(&Key, &ArcPoolTx)> {
        self.sort.iter().next()
    }

    pub fn insert(&mut self, info: &TxInfo) {
        let tx = info.tx().clone();
        self.sort.insert(Key::new(info), tx);
    }
}

pub trait SortableKey: Ord {
    type Value: Clone;

    fn new(info: &TxInfo) -> Self;

    fn value(&self) -> &Self::Value;

    fn tx_id(&self) -> &TxId;
}