holochain_cascade 0.7.0-dev.23

Logic for cascading updates to Holochain state and network interaction
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

use opentelemetry::global::meter;
use opentelemetry::metrics::{Counter, Histogram};
use std::sync::OnceLock;

pub type CascadeDurationMetric = Histogram<f64>;

static DURATION_METRIC: OnceLock<CascadeDurationMetric> = OnceLock::new();

pub fn create_cascade_duration_metric() -> &'static CascadeDurationMetric {
    DURATION_METRIC.get_or_init(|| {
        meter("hc.cascade")
            .f64_histogram("hc.cascade.duration")
            .with_unit("s")
            .with_description("The time taken to execute a cascade query")
            .build()
    })
}

pub type CascadeFetchErrorMetric = Counter<u64>;

static FETCH_ERROR_METRIC: OnceLock<CascadeFetchErrorMetric> = OnceLock::new();

pub fn cascade_fetch_error_metric() -> &'static CascadeFetchErrorMetric {
    FETCH_ERROR_METRIC.get_or_init(|| {
        meter("hc.cascade")
            .u64_counter("hc.cascade.fetch_error")
            .with_description("Number of errors encountered while fetching data from the network.")
            .build()
    })
}