Skip to content

Commit 38fdbf1

Browse files
committed
🐛 try to retrieve service_name from resources for jaeger init (#5)
1 parent 6dd26ff commit 38fdbf1

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

src/tools.rs

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@ use opentelemetry::sdk::Resource;
33
use opentelemetry::{
44
global, sdk::propagation::TraceContextPropagator, sdk::trace as sdktrace, trace::TraceError,
55
};
6+
use opentelemetry_semantic_conventions as semcov;
67

78
#[derive(Clone, Copy, Debug, PartialEq, Eq)]
89
pub enum CollectorKind {
@@ -46,7 +47,6 @@ pub fn make_resource<S>(service_name: S, service_version: S) -> Resource
4647
where
4748
S: Into<String>,
4849
{
49-
use opentelemetry_semantic_conventions as semcov;
5050
Resource::new(vec![
5151
semcov::resource::SERVICE_NAME.string(service_name.into()),
5252
semcov::resource::SERVICE_VERSION.string(service_version.into()),
@@ -85,7 +85,11 @@ pub fn init_tracer_jaeger(resource: Resource) -> Result<sdktrace::Tracer, TraceE
8585
opentelemetry::sdk::propagation::TraceContextPropagator::new(),
8686
);
8787

88-
opentelemetry_jaeger::new_pipeline()
88+
let mut pipeline = opentelemetry_jaeger::new_pipeline();
89+
if let Some(name) = resource.get(semcov::resource::SERVICE_NAME) {
90+
pipeline = pipeline.with_service_name(name.to_string());
91+
}
92+
pipeline
8993
.with_trace_config(
9094
sdktrace::config()
9195
.with_resource(resource)

0 commit comments

Comments
 (0)