provide-telemetry 0.7.0

Cross-language telemetry helpers with privacy, resilience, and OTLP support.
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

// SPDX-FileCopyrightText: Copyright (C) 2026 provide.io llc
// SPDX-License-Identifier: Apache-2.0
// SPDX-Comment: Part of provide-telemetry.
//

use provide_telemetry::{
    get_runtime_config, reconfigure_telemetry, reload_runtime_from_env, setup_telemetry,
    shutdown_telemetry, update_runtime_config, RuntimeOverrides, SamplingConfig, TelemetryError,
};

#[derive(Debug, Clone, PartialEq)]
pub struct DemoSummary {
    pub before_logs_rate: f64,
    pub after_update_logs_rate: f64,
    pub after_reconfigure_logs_rate: f64,
    pub after_reload_logs_rate: f64,
}

fn restore_var(key: &str, previous: Option<String>) {
    match previous {
        Some(value) => std::env::set_var(key, value),
        None => std::env::remove_var(key),
    }
}

pub fn run_demo() -> Result<DemoSummary, TelemetryError> {
    let _ = shutdown_telemetry(None);
    setup_telemetry(None)?;

    let before_logs_rate = get_runtime_config()
        .map(|cfg| cfg.sampling.logs_rate)
        .unwrap_or(1.0);

    let after_update_logs_rate = update_runtime_config(RuntimeOverrides {
        sampling: Some(SamplingConfig {
            logs_rate: 0.0,
            traces_rate: 1.0,
            metrics_rate: 1.0,
        }),
        ..RuntimeOverrides::default()
    })?
    .sampling
    .logs_rate;

    let mut reconfigured = get_runtime_config().unwrap_or_default();
    reconfigured.sampling = SamplingConfig {
        logs_rate: 1.0,
        traces_rate: 1.0,
        metrics_rate: 1.0,
    };
    let after_reconfigure_logs_rate = reconfigure_telemetry(Some(reconfigured))?
        .sampling
        .logs_rate;

    let env_key = "PROVIDE_SAMPLING_LOGS_RATE";
    let previous = std::env::var(env_key).ok();
    std::env::set_var(env_key, "1.0");
    let after_reload_logs_rate = reload_runtime_from_env()?.sampling.logs_rate;
    restore_var(env_key, previous);

    shutdown_telemetry(None)?;
    Ok(DemoSummary {
        before_logs_rate,
        after_update_logs_rate,
        after_reconfigure_logs_rate,
        after_reload_logs_rate,
    })
}