Apply rustfmt and bump aws-smithy-observability to 0.1.6

Author: vcjana

aws/sdk/integration-tests/dynamodb/tests/observability-metrics.rs

@@ -75,7 +75,9 @@ mod mock_otel {
             &self,
             _builder: aws_smithy_observability::instruments::AsyncInstrumentBuilder<
                 '_,
-                std::sync::Arc<dyn aws_smithy_observability::instruments::AsyncMeasure<Value = f64>>,
+                std::sync::Arc<
+                    dyn aws_smithy_observability::instruments::AsyncMeasure<Value = f64>,
+                >,
                 f64,
             >,
         ) -> std::sync::Arc<dyn aws_smithy_observability::instruments::AsyncMeasure<Value = f64>>
@@ -97,7 +99,9 @@ mod mock_otel {
             &self,
             _builder: aws_smithy_observability::instruments::AsyncInstrumentBuilder<
                 '_,
-                std::sync::Arc<dyn aws_smithy_observability::instruments::AsyncMeasure<Value = i64>>,
+                std::sync::Arc<
+                    dyn aws_smithy_observability::instruments::AsyncMeasure<Value = i64>,
+                >,
                 i64,
             >,
         ) -> std::sync::Arc<dyn aws_smithy_observability::instruments::AsyncMeasure<Value = i64>>
@@ -119,7 +123,9 @@ mod mock_otel {
             &self,
             _builder: aws_smithy_observability::instruments::AsyncInstrumentBuilder<
                 '_,
-                std::sync::Arc<dyn aws_smithy_observability::instruments::AsyncMeasure<Value = u64>>,
+                std::sync::Arc<
+                    dyn aws_smithy_observability::instruments::AsyncMeasure<Value = u64>,
+                >,
                 u64,
             >,
         ) -> std::sync::Arc<dyn aws_smithy_observability::instruments::AsyncMeasure<Value = u64>>
@@ -198,7 +204,10 @@ async fn observability_metrics_in_user_agent() {
         let (client, http_client) = test_client(std::convert::identity);
         call_operation(client).await;
         let req = http_client.actual_requests().last().expect("request");
-        let user_agent = req.headers().get("x-amz-user-agent").expect("user-agent header");
+        let user_agent = req
+            .headers()
+            .get("x-amz-user-agent")
+            .expect("user-agent header");
 
         // Should NOT contain observability metrics when using noop provider
         assert!(!user_agent.contains("m/7")); // OBSERVABILITY_OTEL_METRICS = "7"
@@ -210,13 +219,13 @@ async fn observability_metrics_in_user_agent() {
 
         // Create mock OTel meter provider
         let sdk_mp = Arc::new(OtelMeterProvider);
-        
+
         // Debug: Check what the type name actually is
         let type_name = std::any::type_name_of_val(&sdk_mp);
         eprintln!("Mock OTel provider Arc type name: {}", type_name);
         let type_name2 = std::any::type_name_of_val(sdk_mp.as_ref());
         eprintln!("Mock OTel provider as_ref type name: {}", type_name2);
-        
+
         let sdk_tp = TelemetryProvider::builder().meter_provider(sdk_mp).build();
 
         // Set global telemetry provider
@@ -225,7 +234,10 @@ async fn observability_metrics_in_user_agent() {
         let (client, http_client) = test_client(std::convert::identity);
         call_operation(client).await;
         let req = http_client.actual_requests().last().expect("request");
-        let user_agent = req.headers().get("x-amz-user-agent").expect("user-agent header");
+        let user_agent = req
+            .headers()
+            .get("x-amz-user-agent")
+            .expect("user-agent header");
 
         eprintln!("User-Agent: {}", user_agent);
 

codegen-core/src/main/kotlin/software/amazon/smithy/rust/codegen/core/rustlang/CargoDependency.kt

@@ -413,8 +413,7 @@ data class CargoDependency(
         fun smithyMocks(runtimeConfig: RuntimeConfig) =
             runtimeConfig.smithyRuntimeCrate("smithy-mocks", scope = DependencyScope.Dev)
 
-        fun smithyObservability(runtimeConfig: RuntimeConfig) =
-            runtimeConfig.smithyRuntimeCrate("smithy-observability")
+        fun smithyObservability(runtimeConfig: RuntimeConfig) = runtimeConfig.smithyRuntimeCrate("smithy-observability")
 
         fun smithyObservabilityOtel(runtimeConfig: RuntimeConfig) =
             runtimeConfig.smithyRuntimeCrate("smithy-observability-otel")

rust-runtime/Cargo.lock

@@ -13,7 +13,6 @@ rust-version = "1.88"
 [dependencies]
 aws-smithy-observability = { path = "../aws-smithy-observability" }
 opentelemetry = {version = "0.26.0", features = ["metrics"]}
-thiserror = "2.0"  # Required by opentelemetry 0.26.0 but not declared
 # The following dependencies are transitive and pinned for build
 # compatability purposes
 value-bag = "1.10.0"

rust-runtime/aws-smithy-observability-otel/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "aws-smithy-observability"
-version = "0.1.5"
+version = "0.1.6"
 authors = [
   "AWS Rust SDK Team <[email protected]>",
 ]
@@ -23,3 +23,4 @@ targets = ["x86_64-unknown-linux-gnu"]
 cargo-args = ["-Zunstable-options", "-Zrustdoc-scrape-examples"]
 rustdoc-args = ["--cfg", "docsrs"]
 # End of docs.rs metadata
+

rust-runtime/aws-smithy-observability/Cargo.toml

@@ -19,7 +19,13 @@ pub trait ProvideMeter: Send + Sync + Debug {
     fn get_meter(&self, scope: &'static str, attributes: Option<&Attributes>) -> Meter;
 
     /// Returns a reference to `self` as `&dyn Any` for downcasting.
-    fn as_any(&self) -> &dyn std::any::Any;
+    /// 
+    /// The default implementation returns a reference to the unit type,
+    /// which will fail any downcast attempts. Implementations should override
+    /// this to return `self` for proper type inspection.
+    fn as_any(&self) -> &dyn std::any::Any {
+        &()
+    }
 
     /// Returns the name of this provider implementation.
     /// This is used for feature tracking without requiring type imports.