capture: make otel service name configurable, will use deploy name

capture-server/src/main.rs

@@ -31,7 +31,7 @@ async fn shutdown() {
     tracing::info!("Shutting down gracefully...");
 }
 
-fn init_tracer(sink_url: &str, sampling_rate: f64) -> Tracer {
+fn init_tracer(sink_url: &str, sampling_rate: f64, service_name: String) -> Tracer {
     opentelemetry_otlp::new_pipeline()
         .tracing()
         .with_trace_config(
@@ -42,7 +42,7 @@ fn init_tracer(sink_url: &str, sampling_rate: f64) -> Tracer {
                 .with_id_generator(RandomIdGenerator::default())
                 .with_resource(Resource::new(vec![KeyValue::new(
                     "service.name",
-                    "capture",
+                    &service_name,
                 )])),
         )
         .with_batch_config(BatchConfig::default())
@@ -67,7 +67,7 @@ async fn main() {
     let otel_layer = config
         .otel_url
         .clone()
-        .map(|url| OpenTelemetryLayer::new(init_tracer(&url, config.otel_sampling_rate)))
+        .map(|url| OpenTelemetryLayer::new(init_tracer(&url, config.otel_sampling_rate, config.otel_service_name)))
         .with_filter(LevelFilter::from_level(Level::INFO));
     tracing_subscriber::registry()
         .with(log_layer)

capture/src/config.rs

@@ -27,6 +27,9 @@ pub struct Config {
     #[envconfig(default = "1.0")]
     pub otel_sampling_rate: f64,
 
+    #[envconfig(default = "capture")]
+    pub otel_service_name: String,
+
     #[envconfig(default = "true")]
     pub export_prometheus: bool,
 }