fix: cargo fmt

Author: alex-berger

rustrial-k8s-object-syncer-apis/src/lib.rs

@@ -1,7 +1,7 @@
 use std::collections::HashSet;
 
 use k8s_openapi::chrono::{SecondsFormat, Utc};
-use kube::{api::ObjectMeta, CustomResource, ResourceExt};
+use kube::{CustomResource, ResourceExt, api::ObjectMeta};
 
 use schemars::JsonSchema;
 use serde::{Deserialize, Serialize};
@@ -434,33 +434,49 @@ mod tests {
         };
 
         // Do not overwrite source (same name & namespace)
-        assert!(all_namespaces
-            .applies_to(&obj, "source_namespace")
-            .is_none());
-        assert!(source_namespace
-            .applies_to(&obj, "source_namespace")
-            .is_none());
+        assert!(
+            all_namespaces
+                .applies_to(&obj, "source_namespace")
+                .is_none()
+        );
+        assert!(
+            source_namespace
+                .applies_to(&obj, "source_namespace")
+                .is_none()
+        );
         // Apply if not source but same namespace
-        assert!(all_namespaces_other_name
-            .applies_to(&obj, "source_namespace")
-            .is_some());
-        assert!(source_namespace_other_name
-            .applies_to(&obj, "source_namespace")
-            .is_some());
+        assert!(
+            all_namespaces_other_name
+                .applies_to(&obj, "source_namespace")
+                .is_some()
+        );
+        assert!(
+            source_namespace_other_name
+                .applies_to(&obj, "source_namespace")
+                .is_some()
+        );
         // Apply if different namespace
         assert!(all_namespaces.applies_to(&obj, "other_namespace").is_some());
-        assert!(other_namespace
-            .applies_to(&obj, "other_namespace")
-            .is_some());
-        assert!(all_namespaces_other_name
-            .applies_to(&obj, "other_namespace")
-            .is_some());
+        assert!(
+            other_namespace
+                .applies_to(&obj, "other_namespace")
+                .is_some()
+        );
+        assert!(
+            all_namespaces_other_name
+                .applies_to(&obj, "other_namespace")
+                .is_some()
+        );
         // Refuse if destination namespace does not match
-        assert!(source_namespace_other_name
-            .applies_to(&obj, "other_namespace")
-            .is_none());
-        assert!(other_namespace
-            .applies_to(&obj, "source_namespace")
-            .is_none());
+        assert!(
+            source_namespace_other_name
+                .applies_to(&obj, "other_namespace")
+                .is_none()
+        );
+        assert!(
+            other_namespace
+                .applies_to(&obj, "source_namespace")
+                .is_none()
+        );
     }
 }

rustrial-k8s-object-syncer/src/main.rs

@@ -1,14 +1,14 @@
 #[macro_use]
 extern crate log;
 
-use anyhow::{anyhow, Context};
+use anyhow::{Context, anyhow};
 use futures::TryStreamExt;
 use k8s_openapi::api::core::v1::Namespace;
 use kube::{Api, Client};
 use kube_runtime::{
+    WatchStreamExt,
     reflector::{reflector, store::Writer},
     watcher::{self},
-    WatchStreamExt,
 };
 use opentelemetry::global;
 use opentelemetry_sdk::metrics::SdkMeterProvider;

rustrial-k8s-object-syncer/src/prometheus_exporter.rs

@@ -1,10 +1,10 @@
 use http_body_util::Full;
 use hyper::{
+    Request, Response,
     body::{Bytes, Incoming},
     header::CONTENT_TYPE,
     server::conn::http1,
     service::service_fn,
-    Request, Response,
 };
 use hyper_util::rt::TokioIo;
 use prometheus::{Encoder, Registry, TextEncoder};