14294038345

Committed 06 Apr 2025 03:34PM UTC coverage: 84.783%. Remained the same

Build # 14294038345

Build Type

push

github

Committed by

nbari

Commit Message

cargo update

Run Details

0 of 5 new or added lines in 1 file covered. (0.0%)

2028 of 2392 relevant lines covered (84.78%)

82.96 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/cli/telemetry.rs

use anyhow::Result;
use opentelemetry::{global, trace::TracerProvider as _, KeyValue};
use opentelemetry_otlp::WithExportConfig;
use opentelemetry_sdk::{
    trace::{SdkTracerProvider, Tracer},
    Resource,
};
use std::time::Duration;
use tracing::Level;
use tracing_subscriber::{fmt, layer::SubscriberExt, EnvFilter, Registry};

fn init_tracer() -> Result<Tracer> {
    let tracer_provider = SdkTracerProvider::builder()
        .with_batch_exporter(
            opentelemetry_otlp::SpanExporter::builder()
                .with_tonic()
                .with_timeout(Duration::from_secs(3))
                .build()?,
        )
        .with_resource(
            Resource::builder_empty()
                .with_attributes(vec![
                    KeyValue::new("service.name", env!("CARGO_PKG_NAME")),
                    KeyValue::new("service.version", env!("CARGO_PKG_VERSION")),
                ])
                .build(),
        )
        .build();

    global::set_tracer_provider(tracer_provider.clone());

    Ok(tracer_provider.tracer(env!("CARGO_PKG_NAME")))
}

/// Start the telemetry layer
/// # Errors
/// Will return an error if the telemetry layer fails to start
pub fn init(verbosity_level: Option<Level>) -> Result<()> {
    let verbosity_level = verbosity_level.unwrap_or(Level::ERROR);

    let tracer = init_tracer()?;

    let otel_tracer_layer = tracing_opentelemetry::layer().with_tracer(tracer);

    let fmt_layer = fmt::layer()
        .with_file(false)
        .with_line_number(false)
        .with_thread_ids(false)
        .with_thread_names(false)
        .with_target(false)
        .json();

    // RUST_LOG=
    let filter = EnvFilter::builder()
        .with_default_directive(verbosity_level.into())
        .from_env_lossy()
        .add_directive("hyper=error".parse()?)
        .add_directive("tokio=error".parse()?)
        .add_directive("reqwest=error".parse()?);

    let subscriber = Registry::default()
        .with(fmt_layer)
        .with(otel_tracer_layer)
        .with(filter);

    Ok(tracing::subscriber::set_global_default(subscriber)?)
}

1	use anyhow::Result;
2	use opentelemetry::{global, trace::TracerProvider as _, KeyValue};
3	use opentelemetry_otlp::WithExportConfig;
4	use opentelemetry_sdk::{
5	trace::{SdkTracerProvider, Tracer},
6	Resource,
7	};
8	use std::time::Duration;
9	use tracing::Level;
10	use tracing_subscriber::{fmt, layer::SubscriberExt, EnvFilter, Registry};
11
12	fn init_tracer() -> Result<Tracer> {	×
13	let tracer_provider = SdkTracerProvider::builder()	×
NEW 14	.with_batch_exporter(	×
NEW 15	opentelemetry_otlp::SpanExporter::builder()	×
NEW 16	.with_tonic()	×
NEW 17	.with_timeout(Duration::from_secs(3))	×
NEW 18	.build()?,	×
19	)
20	.with_resource(	×
21	Resource::builder_empty()	×
22	.with_attributes(vec![	×
23	KeyValue::new("service.name", env!("CARGO_PKG_NAME")),	×
24	KeyValue::new("service.version", env!("CARGO_PKG_VERSION")),	×
25	])	×
26	.build(),	×
27	)	×
28	.build();	×
29		×
30	global::set_tracer_provider(tracer_provider.clone());	×
31		×
32	Ok(tracer_provider.tracer(env!("CARGO_PKG_NAME")))	×
33	}	×
34
35	/// Start the telemetry layer
36	/// # Errors
37	/// Will return an error if the telemetry layer fails to start
38	pub fn init(verbosity_level: Option<Level>) -> Result<()> {	×
39	let verbosity_level = verbosity_level.unwrap_or(Level::ERROR);	×
40
41	let tracer = init_tracer()?;	×
42
43	let otel_tracer_layer = tracing_opentelemetry::layer().with_tracer(tracer);	×
44		×
45	let fmt_layer = fmt::layer()	×
46	.with_file(false)	×
47	.with_line_number(false)	×
48	.with_thread_ids(false)	×
49	.with_thread_names(false)	×
50	.with_target(false)	×
51	.json();	×
52
53	// RUST_LOG=
54	let filter = EnvFilter::builder()	×
55	.with_default_directive(verbosity_level.into())	×
56	.from_env_lossy()	×
57	.add_directive("hyper=error".parse()?)	×
58	.add_directive("tokio=error".parse()?)	×
59	.add_directive("reqwest=error".parse()?);	×
60
61	let subscriber = Registry::default()	×
62	.with(fmt_layer)	×
63	.with(otel_tracer_layer)	×
64	.with(filter);	×
65		×
66	Ok(tracing::subscriber::set_global_default(subscriber)?)	×
67	}	×

epazote / epazote / 14294038345

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous