brk_computer 0.3.0-alpha.2

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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75

use brk_traversable::Traversable;
use brk_types::{Height, Version};
use schemars::JsonSchema;
use vecdb::{LazyVecFrom1, ReadableCloneableVec, UnaryTransform, VecIndex};

use crate::internal::{ComputedVecValue, DistributionStats, PerBlockDistribution};

/// Lazy analog of `Distribution<T>`: 7 `LazyVecFrom1` fields,
/// each derived by transforming the corresponding field of a source `PerBlockDistribution<S1T>`.
#[derive(Clone, Traversable)]
pub struct LazyDistribution<I, T, S1T>
where
    I: VecIndex,
    T: ComputedVecValue + JsonSchema,
    S1T: ComputedVecValue,
{
    pub min: LazyVecFrom1<I, T, I, S1T>,
    pub max: LazyVecFrom1<I, T, I, S1T>,
    pub pct10: LazyVecFrom1<I, T, I, S1T>,
    pub pct25: LazyVecFrom1<I, T, I, S1T>,
    pub median: LazyVecFrom1<I, T, I, S1T>,
    pub pct75: LazyVecFrom1<I, T, I, S1T>,
    pub pct90: LazyVecFrom1<I, T, I, S1T>,
}

impl<T, S1T> LazyDistribution<Height, T, S1T>
where
    T: ComputedVecValue + JsonSchema + 'static,
    S1T: ComputedVecValue + PartialOrd + JsonSchema,
{
    pub(crate) fn from_distribution<F: UnaryTransform<S1T, T>>(
        name: &str,
        version: Version,
        source: &PerBlockDistribution<S1T>,
    ) -> Self {
        let s = DistributionStats::<()>::SUFFIXES;
        Self {
            min: LazyVecFrom1::transformed::<F>(
                &format!("{name}_{}", s[0]),
                version,
                source.min.height.read_only_boxed_clone(),
            ),
            max: LazyVecFrom1::transformed::<F>(
                &format!("{name}_{}", s[1]),
                version,
                source.max.height.read_only_boxed_clone(),
            ),
            pct10: LazyVecFrom1::transformed::<F>(
                &format!("{name}_{}", s[2]),
                version,
                source.pct10.height.read_only_boxed_clone(),
            ),
            pct25: LazyVecFrom1::transformed::<F>(
                &format!("{name}_{}", s[3]),
                version,
                source.pct25.height.read_only_boxed_clone(),
            ),
            median: LazyVecFrom1::transformed::<F>(
                &format!("{name}_{}", s[4]),
                version,
                source.median.height.read_only_boxed_clone(),
            ),
            pct75: LazyVecFrom1::transformed::<F>(
                &format!("{name}_{}", s[5]),
                version,
                source.pct75.height.read_only_boxed_clone(),
            ),
            pct90: LazyVecFrom1::transformed::<F>(
                &format!("{name}_{}", s[6]),
                version,
                source.pct90.height.read_only_boxed_clone(),
            ),
        }
    }
}