commonware-runtime 2026.9.0

Execute asynchronous tasks with a configurable scheduler.
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

//! Utilities to export traces to an OTLP endpoint.

use commonware_utils::Probability;
use opentelemetry::{global, trace::TracerProvider};
use opentelemetry_otlp::{ExporterBuildError, SpanExporter, WithExportConfig};
use opentelemetry_sdk::{
    Resource,
    trace::{BatchSpanProcessor, Sampler, SdkTracerProvider, Tracer},
};
use std::time::Duration;

/// Timeout for the OTLP HTTP exporter.
const TIMEOUT: Duration = Duration::from_secs(15);

/// Configuration for exporting traces to an OTLP endpoint.
pub struct Config {
    /// The OTLP endpoint to export traces to.
    pub endpoint: String,
    /// The service name to use for the traces.
    pub name: String,
    /// The sampling rate to use for the traces.
    pub rate: Probability,
}

/// Export traces to an OTLP endpoint.
pub fn export(cfg: Config) -> Result<Tracer, ExporterBuildError> {
    // Create the OTLP HTTP exporter
    let exporter = SpanExporter::builder()
        .with_http()
        .with_endpoint(cfg.endpoint)
        .with_timeout(TIMEOUT)
        .build()?;

    // Configure the batch processor
    let batch_processor = BatchSpanProcessor::builder(exporter).build();

    // Define the resource with service name
    let resource = Resource::builder_empty()
        .with_service_name(cfg.name.clone())
        .build();

    // Build the tracer provider
    let sampler = Sampler::TraceIdRatioBased(cfg.rate.as_f64());
    let tracer_provider = SdkTracerProvider::builder()
        .with_span_processor(batch_processor)
        .with_resource(resource)
        .with_sampler(sampler)
        .build();

    // Create the tracer and set it globally
    let tracer = tracer_provider.tracer(cfg.name);
    global::set_tracer_provider(tracer_provider);
    Ok(tracer)
}