|
1 |
| -//! run with `$ cargo run --example basic --all-features |
2 |
| -
|
3 |
| -#[cfg(all(feature = "metrics", feature = "trace"))] |
4 |
| -use opentelemetry::{ |
5 |
| - global, |
6 |
| - trace::{Span, Tracer, TracerProvider as _}, |
7 |
| - KeyValue, |
8 |
| -}; |
9 |
| -#[cfg(all(feature = "metrics", feature = "trace"))] |
10 |
| -use opentelemetry_sdk::{ |
11 |
| - metrics::{PeriodicReader, SdkMeterProvider}, |
12 |
| - runtime, |
13 |
| - trace::TracerProvider, |
14 |
| -}; |
15 |
| - |
16 |
| -#[cfg(all(feature = "metrics", feature = "trace"))] |
17 |
| -fn init_trace() -> TracerProvider { |
| 1 | +//! run with `$ cargo run --example basic |
| 2 | +
|
| 3 | +use opentelemetry::{global, KeyValue}; |
| 4 | + |
| 5 | +#[cfg(feature = "trace")] |
| 6 | +use opentelemetry::trace::{Span, Tracer}; |
| 7 | + |
| 8 | +#[cfg(feature = "metrics")] |
| 9 | +use opentelemetry_sdk::runtime; |
| 10 | + |
| 11 | +#[cfg(feature = "metrics")] |
| 12 | +use opentelemetry_sdk::metrics::{PeriodicReader, SdkMeterProvider}; |
| 13 | + |
| 14 | +#[cfg(feature = "trace")] |
| 15 | +use opentelemetry_sdk::trace::TracerProvider; |
| 16 | + |
| 17 | +#[cfg(feature = "trace")] |
| 18 | +fn init_trace() { |
18 | 19 | let exporter = opentelemetry_stdout::SpanExporter::default();
|
19 |
| - TracerProvider::builder() |
| 20 | + let provider = TracerProvider::builder() |
20 | 21 | .with_simple_exporter(exporter)
|
21 |
| - .build() |
| 22 | + .build(); |
| 23 | + global::set_tracer_provider(provider); |
22 | 24 | }
|
23 | 25 |
|
24 |
| -#[cfg(all(feature = "metrics", feature = "trace"))] |
| 26 | +#[cfg(feature = "metrics")] |
25 | 27 | fn init_metrics() {
|
26 | 28 | let exporter = opentelemetry_stdout::MetricsExporter::default();
|
27 | 29 | let reader = PeriodicReader::builder(exporter, runtime::Tokio).build();
|
28 | 30 | let provider = SdkMeterProvider::builder().with_reader(reader).build();
|
29 | 31 | global::set_meter_provider(provider);
|
30 | 32 | }
|
31 | 33 |
|
32 |
| -#[tokio::main] |
33 |
| -#[cfg(all(feature = "metrics", feature = "trace"))] |
34 |
| -async fn main() -> Result<(), Box<dyn std::error::Error>> { |
35 |
| - let tracer_provider = init_trace(); |
36 |
| - init_metrics(); |
37 |
| - |
38 |
| - let tracer = tracer_provider.tracer("stdout-test"); |
| 34 | +#[cfg(feature = "trace")] |
| 35 | +fn emit_span() { |
| 36 | + let tracer = global::tracer("stdout-test"); |
39 | 37 | let mut span = tracer.start("test_span");
|
40 | 38 | span.set_attribute(KeyValue::new("test_key", "test_value"));
|
41 | 39 | span.add_event(
|
42 | 40 | "test_event",
|
43 | 41 | vec![KeyValue::new("test_event_key", "test_event_value")],
|
44 | 42 | );
|
45 | 43 | span.end();
|
| 44 | +} |
46 | 45 |
|
| 46 | +#[cfg(feature = "metrics")] |
| 47 | +fn emit_metrics() { |
47 | 48 | let meter = global::meter("stdout-test");
|
48 |
| - let c = meter.u64_counter("test_events").init(); |
| 49 | + let c = meter.u64_counter("test_counter").init(); |
49 | 50 | c.add(1, &[KeyValue::new("test_key", "test_value")]);
|
| 51 | +} |
| 52 | + |
| 53 | +#[tokio::main] |
| 54 | +async fn main() -> Result<(), Box<dyn std::error::Error>> { |
| 55 | + #[cfg(feature = "trace")] |
| 56 | + init_trace(); |
| 57 | + |
| 58 | + #[cfg(feature = "metrics")] |
| 59 | + init_metrics(); |
| 60 | + |
| 61 | + #[cfg(feature = "trace")] |
| 62 | + emit_span(); |
| 63 | + |
| 64 | + #[cfg(feature = "metrics")] |
| 65 | + emit_metrics(); |
| 66 | + |
| 67 | + #[cfg(feature = "trace")] |
| 68 | + global::shutdown_tracer_provider(); |
50 | 69 |
|
| 70 | + #[cfg(feature = "metrics")] |
51 | 71 | global::shutdown_meter_provider();
|
52 | 72 |
|
53 | 73 | Ok(())
|
54 | 74 | }
|
55 |
| -#[cfg(not(all(feature = "metrics", feature = "trace")))] |
56 |
| -fn main() {} |
|
0 commit comments