fmt

Author: gruebel

opentelemetry-jaeger-propagator/src/propagator.rs

@@ -641,10 +641,7 @@ mod tests {
         }
         for (trace_id, span_id, flag, expected) in get_extract_data() {
             let mut map: HashMap<String, String> = HashMap::new();
-            map.set(
-                JAEGER_HEADER,
-                format!("{trace_id}:{span_id}:0:{flag}"),
-            );
+            map.set(JAEGER_HEADER, format!("{trace_id}:{span_id}:0:{flag}"));
             let context = propagator.extract(&map);
             assert_eq!(context.span().span_context(), &expected);
         }

opentelemetry-otlp/tests/integration_test/src/metric_helpers.rs

@@ -160,11 +160,7 @@ pub fn fetch_latest_metrics_for_scope(scope_name: &str) -> Result<Value> {
                     None
                 })
         })
-        .with_context(|| {
-            format!(
-                "No valid JSON line containing scope `{scope_name}` found."
-            )
-        })?;
+        .with_context(|| format!("No valid JSON line containing scope `{scope_name}` found."))?;
 
     Ok(json_line)
 }
@@ -183,9 +179,8 @@ pub fn validate_metrics_against_results(scope_name: &str) -> Result<()> {
 
     // Read the expected metrics from the results file
     let expected_metrics = {
-        let file = File::open(&results_file_path).context(format!(
-            "Failed to open results file: {results_file_path}"
-        ))?;
+        let file = File::open(&results_file_path)
+            .context(format!("Failed to open results file: {results_file_path}"))?;
         read_metrics_from_json(file)
     }?;
 

opentelemetry-sdk/benches/metric.rs

@@ -312,10 +312,9 @@ fn histograms(c: &mut Criterion) {
                 ))
             }
             let value: u64 = rng.random_range(0..MAX_BOUND).try_into().unwrap();
-            group.bench_function(
-                format!("Record{attr_size}Attrs{bound_size}bounds"),
-                |b| b.iter(|| hist.record(value, &attributes)),
-            );
+            group.bench_function(format!("Record{attr_size}Attrs{bound_size}bounds"), |b| {
+                b.iter(|| hist.record(value, &attributes))
+            });
         }
     }
     group.bench_function("CollectOne", |b| benchmark_collect_histogram(b, 1));

opentelemetry-sdk/src/metrics/internal/exponential_histogram.rs

@@ -1635,10 +1635,7 @@ mod tests {
         assert_eq!(a.sum, b.sum, "{test_name}: {message} sum");
 
         assert_eq!(a.scale, b.scale, "{test_name}: {message} scale");
-        assert_eq!(
-            a.zero_count, b.zero_count,
-            "{test_name}: {message} zeros"
-        );
+        assert_eq!(a.zero_count, b.zero_count, "{test_name}: {message} zeros");
 
         assert_eq!(
             a.positive_bucket, b.positive_bucket,

opentelemetry-sdk/src/trace/in_memory_exporter.rs

@@ -135,9 +135,7 @@ impl SpanExporter for InMemorySpanExporter {
             .spans
             .lock()
             .map(|mut spans_guard| spans_guard.append(&mut batch.clone()))
-            .map_err(|err| {
-                OTelSdkError::InternalFailure(format!("Failed to lock spans: {err:?}"))
-            });
+            .map_err(|err| OTelSdkError::InternalFailure(format!("Failed to lock spans: {err:?}")));
         result
     }
 

opentelemetry-zipkin/src/exporter/uploader.rs

@@ -45,14 +45,13 @@ impl JsonV2Client {
             .uri(self.collector_endpoint.clone())
             .header(CONTENT_TYPE, "application/json")
             .body(body.into())
-            .map_err(|e| {
-                OTelSdkError::InternalFailure(format!("Failed to create request: {e}"))
-            })?;
+            .map_err(|e| OTelSdkError::InternalFailure(format!("Failed to create request: {e}")))?;
 
-        let response =
-            self.client.send_bytes(req).await.map_err(|e| {
-                OTelSdkError::InternalFailure(format!("HTTP request failed: {e}"))
-            })?;
+        let response = self
+            .client
+            .send_bytes(req)
+            .await
+            .map_err(|e| OTelSdkError::InternalFailure(format!("HTTP request failed: {e}")))?;
 
         response
             .error_for_status()