init-tracing-opentelemetry 0.17.1

A set of helpers to initialize (and more) tracing + opentelemetry (compose your own or use opinionated preset)
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

use opentelemetry::trace::TraceError;
use opentelemetry_jaeger::config::agent::AgentPipeline;
use opentelemetry_sdk::{
    trace::{config, Sampler, Tracer},
    Resource,
};
use opentelemetry_semantic_conventions as semcov;

#[must_use]
pub fn identity(v: AgentPipeline) -> AgentPipeline {
    v
}

/// Setup a jaeger agent pipeline with the trace-context propagator and the service name.
/// The jaeger pipeline builder can be configured dynamically via environment variables.
/// All variables are optional, a full list of accepted options can be found in the
/// [jaeger variables spec](https://github.com/open-telemetry/opentelemetry-specification/blob/main/specification/sdk-environment-variables.md#jaeger-exporter).
pub fn init_tracer<F>(resource: Resource, transform: F) -> Result<Tracer, TraceError>
where
    F: FnOnce(AgentPipeline) -> AgentPipeline,
{
    let mut pipeline = opentelemetry_jaeger::new_agent_pipeline();
    if let Some(name) = resource.get(semcov::resource::SERVICE_NAME) {
        pipeline = pipeline.with_service_name(name.to_string());
    }
    pipeline = pipeline.with_trace_config(
        config()
            .with_resource(resource)
            .with_sampler(Sampler::AlwaysOn),
    );
    pipeline = transform(pipeline);
    pipeline.install_batch(opentelemetry_sdk::runtime::Tokio)
}