chore(metrics): Remove the Arc (#2357)

Author: grahamking

lib/runtime/examples/Cargo.lock

@@ -1,17 +1,5 @@
 # SPDX-FileCopyrightText: Copyright (c) 2025 NVIDIA CORPORATION & AFFILIATES. All rights reserved.
 # SPDX-License-Identifier: Apache-2.0
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
 
 [package]
 name = "system_metrics"
@@ -27,6 +15,7 @@ default = []
 integration = [] # Integration tests that require NATS
 
 [dependencies]
+anyhow = "*"
 dynamo-runtime = { workspace = true }
 
 # third-party

lib/runtime/examples/system_metrics/Cargo.toml

@@ -1,17 +1,5 @@
 // SPDX-FileCopyrightText: Copyright (c) 2024-2025 NVIDIA CORPORATION & AFFILIATES. All rights reserved.
 // SPDX-License-Identifier: Apache-2.0
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
 
 use dynamo_runtime::{
     metrics::MetricsRegistry,
@@ -39,13 +27,11 @@ pub struct MyStats {
 /// Custom metrics for system stats with data bytes tracking
 #[derive(Clone, Debug)]
 pub struct MySystemStatsMetrics {
-    pub data_bytes_processed: Arc<IntCounter>,
+    pub data_bytes_processed: IntCounter,
 }
 
 impl MySystemStatsMetrics {
-    pub fn from_endpoint(
-        endpoint: &dynamo_runtime::component::Endpoint,
-    ) -> Result<Self, Box<dyn std::error::Error + Send + Sync>> {
+    pub fn from_endpoint(endpoint: &dynamo_runtime::component::Endpoint) -> anyhow::Result<Self> {
         let data_bytes_processed = endpoint.create_intcounter(
             "my_custom_bytes_processed_total",
             "Example of a custom metric. Total number of data bytes processed by system handler",
@@ -60,7 +46,7 @@ impl MySystemStatsMetrics {
 
 #[derive(Clone)]
 pub struct RequestHandler {
-    metrics: Option<Arc<MySystemStatsMetrics>>,
+    metrics: Option<MySystemStatsMetrics>,
 }
 
 impl RequestHandler {
@@ -70,7 +56,7 @@ impl RequestHandler {
 
     pub fn with_metrics(metrics: MySystemStatsMetrics) -> Arc<Self> {
         Arc::new(Self {
-            metrics: Some(Arc::new(metrics)),
+            metrics: Some(metrics),
         })
     }
 }