|
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(); |
| 34 | +#[cfg(feature = "logs")] |
| 35 | +fn init_logs() -> opentelemetry_sdk::logs::LoggerProvider { |
| 36 | + use opentelemetry_appender_tracing::layer; |
| 37 | + use opentelemetry_sdk::logs::LoggerProvider; |
| 38 | + use tracing_subscriber::prelude::*; |
| 39 | + |
| 40 | + let exporter = opentelemetry_stdout::LogExporter::default(); |
| 41 | + let provider: LoggerProvider = LoggerProvider::builder() |
| 42 | + .with_simple_exporter(exporter) |
| 43 | + .build(); |
| 44 | + let layer = layer::OpenTelemetryTracingBridge::new(&provider); |
| 45 | + tracing_subscriber::registry().with(layer).init(); |
| 46 | + provider |
| 47 | +} |
37 | 48 |
|
38 |
| - let tracer = tracer_provider.tracer("stdout-test"); |
| 49 | +#[cfg(feature = "trace")] |
| 50 | +fn emit_span() { |
| 51 | + let tracer = global::tracer("stdout-test"); |
39 | 52 | let mut span = tracer.start("test_span");
|
40 | 53 | span.set_attribute(KeyValue::new("test_key", "test_value"));
|
41 | 54 | span.add_event(
|
42 | 55 | "test_event",
|
43 | 56 | vec![KeyValue::new("test_event_key", "test_event_value")],
|
44 | 57 | );
|
45 | 58 | span.end();
|
| 59 | +} |
46 | 60 |
|
| 61 | +#[cfg(feature = "metrics")] |
| 62 | +fn emit_metrics() { |
47 | 63 | let meter = global::meter("stdout-test");
|
48 |
| - let c = meter.u64_counter("test_events").init(); |
| 64 | + let c = meter.u64_counter("test_counter").init(); |
49 | 65 | c.add(1, &[KeyValue::new("test_key", "test_value")]);
|
| 66 | +} |
| 67 | + |
| 68 | +#[cfg(feature = "logs")] |
| 69 | +fn emit_log() { |
| 70 | + use tracing::error; |
| 71 | + error!(name: "my-event-name", target: "my-system", event_id = 20, user_name = "otel", user_email = "otel@opentelemetry.io"); |
| 72 | +} |
50 | 73 |
|
| 74 | +#[tokio::main] |
| 75 | +async fn main() -> Result<(), Box<dyn std::error::Error>> { |
| 76 | + #[cfg(feature = "trace")] |
| 77 | + init_trace(); |
| 78 | + |
| 79 | + #[cfg(feature = "metrics")] |
| 80 | + init_metrics(); |
| 81 | + |
| 82 | + #[cfg(feature = "logs")] |
| 83 | + let logger_provider = init_logs(); |
| 84 | + |
| 85 | + #[cfg(feature = "logs")] |
| 86 | + emit_log(); |
| 87 | + |
| 88 | + println!( |
| 89 | + "======================================================================================" |
| 90 | + ); |
| 91 | + |
| 92 | + #[cfg(feature = "trace")] |
| 93 | + emit_span(); |
| 94 | + |
| 95 | + println!( |
| 96 | + "======================================================================================" |
| 97 | + ); |
| 98 | + |
| 99 | + #[cfg(feature = "metrics")] |
| 100 | + emit_metrics(); |
| 101 | + |
| 102 | + #[cfg(feature = "trace")] |
| 103 | + global::shutdown_tracer_provider(); |
| 104 | + |
| 105 | + #[cfg(feature = "metrics")] |
51 | 106 | global::shutdown_meter_provider();
|
52 | 107 |
|
| 108 | + #[cfg(feature = "logs")] |
| 109 | + drop(logger_provider); |
| 110 | + |
53 | 111 | Ok(())
|
54 | 112 | }
|
55 |
| -#[cfg(not(all(feature = "metrics", feature = "trace")))] |
56 |
| -fn main() {} |
|
0 commit comments