opentelemetry-zipkin 0.30.0

Zipkin exporter for OpenTelemetry
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

use opentelemetry::{
    global::{self},
    trace::{Span, Tracer},
    InstrumentationScope, KeyValue,
};
use opentelemetry_sdk::{trace::SdkTracerProvider, Resource};
use opentelemetry_zipkin::{ExporterBuildError, ZipkinExporter};
use std::thread;
use std::time::Duration;

fn bar() {
    let tracer = global::tracer("component-bar");
    let mut span = tracer.start("bar");
    thread::sleep(Duration::from_millis(6));
    span.end()
}

fn init_traces() -> Result<SdkTracerProvider, ExporterBuildError> {
    let exporter = ZipkinExporter::builder().build()?;

    Ok(SdkTracerProvider::builder()
        .with_simple_exporter(exporter)
        .with_resource(
            Resource::builder_empty()
                .with_service_name("trace-demo")
                .build(),
        )
        .build())
}

fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync + 'static>> {
    let provider = init_traces()?;
    global::set_tracer_provider(provider.clone());

    let common_scope_attributes = vec![KeyValue::new("scope-key", "scope-value")];
    let scope = InstrumentationScope::builder("opentelemetry-zipkin")
        .with_version(env!("CARGO_PKG_VERSION"))
        .with_attributes(common_scope_attributes)
        .build();
    let tracer = global::tracer_with_scope(scope.clone());

    tracer.in_span("foo", |_cx| {
        thread::sleep(Duration::from_millis(6));
        bar();
        thread::sleep(Duration::from_millis(6));
    });

    provider.shutdown()?;
    Ok(())
}