brk_computer 0.2.5

A Bitcoin dataset computer built on top of brk_indexer
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

use brk_indexer::Indexer;
use brk_traversable::Traversable;
use brk_types::{StoredU64, TxIndex, Txid, Version};
use vecdb::{
    Database, EagerVec, ImportableVec, LazyVecFrom1, PcoVec, ReadableCloneableVec, Rw, StorageMode,
};

use brk_error::Result;

#[derive(Traversable)]
pub struct Vecs<M: StorageMode = Rw> {
    pub identity: LazyVecFrom1<TxIndex, TxIndex, TxIndex, Txid>,
    pub input_count: M::Stored<EagerVec<PcoVec<TxIndex, StoredU64>>>,
    pub output_count: M::Stored<EagerVec<PcoVec<TxIndex, StoredU64>>>,
}

impl Vecs {
    pub(crate) fn forced_import(
        db: &Database,
        version: Version,
        indexer: &Indexer,
    ) -> Result<Self> {
        Ok(Self {
            identity: LazyVecFrom1::init(
                "tx_index",
                version,
                indexer.vecs.transactions.txid.read_only_boxed_clone(),
                |index, _| index,
            ),
            input_count: EagerVec::forced_import(db, "input_count", version)?,
            output_count: EagerVec::forced_import(db, "output_count", version)?,
        })
    }
}