Fix cargo fmt and Arc impl

Author: kthui

Cargo.toml

@@ -63,7 +63,7 @@ libc = { version = "0.2" }
 oneshot = { version = "0.1.11", features = ["std", "async"] }
 prometheus = { version = "0.14" }
 rand = { version = "0.9.0" }
-serde = { version = "1", features = ["derive"] }
+serde = { version = "1", features = ["derive", "rc"] }
 serde_json = { version = "1" }
 strum = { version = "0.27", features = ["derive"] }
 tempfile = "3"

lib/runtime/src/component/client.rs

@@ -144,7 +144,8 @@ impl Client {
         let instances = self.instances();
         let mut inhibited = self.instance_inhibited.lock().await;
 
-        instances.into_iter()
+        instances
+            .into_iter()
             .filter_map(|instance| {
                 let id = instance.id();
                 if let Some(&timestamp) = inhibited.get(&id) {

lib/runtime/src/pipeline/network/egress/push_router.rs

@@ -124,7 +124,8 @@ where
 
             Ok(instance_id)
         };
-        self.generate_with_fault_tolerance(routing_algorithm, request).await
+        self.generate_with_fault_tolerance(routing_algorithm, request)
+            .await
     }
 
     /// Issue a request to a random endpoint
@@ -147,7 +148,8 @@ where
             tracing::trace!("random router selected {instance_id}");
             Ok(instance_id)
         };
-        self.generate_with_fault_tolerance(routing_algorithm, request).await
+        self.generate_with_fault_tolerance(routing_algorithm, request)
+            .await
     }
 
     /// Issue a request to a specific endpoint
@@ -171,7 +173,8 @@ where
             }
             Ok(instance_id)
         };
-        self.generate_with_fault_tolerance(routing_algorithm, request).await
+        self.generate_with_fault_tolerance(routing_algorithm, request)
+            .await
     }
 
     pub async fn r#static(&self, request: SingleIn<T>) -> anyhow::Result<ManyOut<U>> {
@@ -182,7 +185,11 @@ where
         self.addressed.generate(request).await
     }
 
-    async fn generate_with_fault_tolerance<F, R>(&self, routing_algorithm: F, request: SingleIn<T>) -> anyhow::Result<ManyOut<U>>
+    async fn generate_with_fault_tolerance<F, R>(
+        &self,
+        routing_algorithm: F,
+        request: SingleIn<T>,
+    ) -> anyhow::Result<ManyOut<U>>
     where
         F: Fn() -> R,
         R: Future<Output = anyhow::Result<i64>>,
@@ -194,7 +201,8 @@ where
             let instance_id = routing_algorithm().await?;
 
             let subject = self.client.endpoint.subject_to(instance_id);
-            let request = SingleIn::from(req_data.clone()).map(|req| AddressedRequest::new(req, subject));
+            let request =
+                SingleIn::from(req_data.clone()).map(|req| AddressedRequest::new(req, subject));
 
             let stream = self.addressed.generate(request).await;
             if stream.is_ok() {