holochain 0.6.0

Holochain, a framework for distributed applications
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

use holo_hash::{AgentPubKey, DnaHash};
use opentelemetry_api::{global::meter_with_version, metrics::*, KeyValue};
use std::sync::Arc;

pub type WorkflowDurationMetric = Histogram<f64>;

pub fn create_workflow_duration_metric(
    workflow_name: String,
    dna_hash: Arc<DnaHash>,
    agent: Option<AgentPubKey>,
) -> WorkflowDurationMetric {
    let mut attr = vec![
        KeyValue::new("workflow", workflow_name),
        KeyValue::new("dna_hash", format!("{dna_hash:?}")),
    ];

    if let Some(agent) = agent {
        attr.push(KeyValue::new("agent", format!("{agent:?}")));
    }

    meter_with_version(
        "hc.conductor",
        None::<&'static str>,
        None::<&'static str>,
        Some(attr),
    )
    .f64_histogram("hc.conductor.workflow.duration")
    .with_unit(Unit::new("s"))
    .with_description("The time spent running a workflow")
    .init()
}