chore: Apply formatting

Author: Techassi

rust/crd/src/affinity.rs

@@ -76,12 +76,9 @@ pub fn get_affinity(
 
 #[cfg(test)]
 mod tests {
-    use super::*;
-
-    use rstest::rstest;
     use std::collections::BTreeMap;
 
-    use crate::DruidCluster;
+    use rstest::rstest;
     use stackable_operator::{
         commons::affinity::StackableAffinity,
         k8s_openapi::{
@@ -92,6 +89,9 @@ mod tests {
         },
     };
 
+    use super::*;
+    use crate::DruidCluster;
+
     #[rstest]
     #[case(DruidRole::Coordinator)]
     #[case(DruidRole::Broker)]

rust/crd/src/authentication.rs

@@ -232,19 +232,14 @@ impl AuthenticationClassesResolved {
 
 #[cfg(test)]
 mod tests {
-    use indoc::formatdoc;
-    use oidc::ClientAuthenticationOptions;
-
-    use crate::DruidClusterConfig;
-
     use std::pin::Pin;
 
-    use indoc::indoc;
+    use indoc::{formatdoc, indoc};
+    use oidc::ClientAuthenticationOptions;
     use stackable_operator::kube;
 
     use super::*;
-
-    use crate::authentication::AuthenticationClassesResolved;
+    use crate::{authentication::AuthenticationClassesResolved, DruidClusterConfig};
 
     const BASE_CLUSTER_CONFIG: &str = r#"
 deepStorage:

rust/crd/src/lib.rs

@@ -7,12 +7,7 @@ pub mod security;
 pub mod storage;
 pub mod tls;
 
-use crate::{
-    affinity::get_affinity,
-    authorization::DruidAuthorization,
-    resource::RoleResource,
-    tls::{default_druid_tls, DruidTls},
-};
+use std::collections::{BTreeMap, HashMap, HashSet};
 
 use indoc::formatdoc;
 use product_config::types::PropertyNameKind;
@@ -55,9 +50,15 @@ use stackable_operator::{
         COMMON_BASH_TRAP_FUNCTIONS,
     },
 };
-use std::collections::{BTreeMap, HashMap, HashSet};
 use strum::{Display, EnumDiscriminants, EnumIter, EnumString, IntoStaticStr};
 
+use crate::{
+    affinity::get_affinity,
+    authorization::DruidAuthorization,
+    resource::RoleResource,
+    tls::{default_druid_tls, DruidTls},
+};
+
 pub const APP_NAME: &str = "druid";
 pub const OPERATOR_NAME: &str = "druid.stackable.tech";
 

rust/crd/src/memory.rs

@@ -167,9 +167,10 @@ fn format_for_druid(memory_quantity: &MemoryQuantity) -> String {
 
 #[cfg(test)]
 mod tests {
-    use super::*;
     use rstest::*;
 
+    use super::*;
+
     #[rstest]
     #[case(1000, 1)]
     #[case(1400, 1)]

rust/crd/src/resource.rs

@@ -1,13 +1,8 @@
-use std::collections::BTreeMap;
-use std::sync::LazyLock;
+use std::{collections::BTreeMap, sync::LazyLock};
 
-use crate::memory::{HistoricalDerivedSettings, RESERVED_OS_MEMORY};
-use crate::storage::{self, default_free_percentage_empty_dir_fragment};
-use crate::{DruidRole, PATH_SEGMENT_CACHE, PROP_SEGMENT_CACHE_LOCATIONS};
 use snafu::{OptionExt, ResultExt, Snafu};
-use stackable_operator::builder;
-use stackable_operator::memory::MemoryQuantity;
 use stackable_operator::{
+    builder,
     builder::pod::{container::ContainerBuilder, volume::VolumeBuilder, PodBuilder},
     commons::resources::{
         CpuLimitsFragment, MemoryLimits, MemoryLimitsFragment, NoRuntimeLimits,
@@ -17,9 +12,16 @@ use stackable_operator::{
         api::core::v1::{EmptyDirVolumeSource, ResourceRequirements},
         apimachinery::pkg::api::resource::Quantity,
     },
+    memory::MemoryQuantity,
 };
 use strum::{EnumDiscriminants, IntoStaticStr};
 
+use crate::{
+    memory::{HistoricalDerivedSettings, RESERVED_OS_MEMORY},
+    storage::{self, default_free_percentage_empty_dir_fragment},
+    DruidRole, PATH_SEGMENT_CACHE, PROP_SEGMENT_CACHE_LOCATIONS,
+};
+
 // volume names
 const SEGMENT_CACHE_VOLUME_NAME: &str = "segment-cache";
 
@@ -242,13 +244,6 @@ pub static ROUTER_RESOURCES: LazyLock<ResourcesFragment<storage::DruidStorage, N
 
 #[cfg(test)]
 mod test {
-    use super::*;
-    use crate::{
-        storage::{default_free_percentage_empty_dir, HistoricalStorage},
-        tests::deserialize_yaml_file,
-        DruidCluster, MiddleManagerConfig,
-    };
-
     use rstest::*;
     use stackable_operator::{
         commons::resources::{
@@ -259,6 +254,13 @@ mod test {
         role_utils::{CommonConfiguration, RoleGroup},
     };
 
+    use super::*;
+    use crate::{
+        storage::{default_free_percentage_empty_dir, HistoricalStorage},
+        tests::deserialize_yaml_file,
+        DruidCluster, MiddleManagerConfig,
+    };
+
     #[rstest]
     #[case(
         Some(ResourcesFragment{

rust/crd/src/security.rs

@@ -1,8 +1,5 @@
-use crate::{
-    authentication::{self, AuthenticationClassesResolved},
-    DruidCluster, DruidRole, METRICS_PORT,
-};
-use crate::{STACKABLE_TRUST_STORE, STACKABLE_TRUST_STORE_PASSWORD};
+use std::collections::BTreeMap;
+
 use snafu::{ResultExt, Snafu};
 use stackable_operator::{
     builder::{
@@ -23,7 +20,10 @@ use stackable_operator::{
     time::Duration,
 };
 
-use std::collections::BTreeMap;
+use crate::{
+    authentication::{self, AuthenticationClassesResolved},
+    DruidCluster, DruidRole, METRICS_PORT, STACKABLE_TRUST_STORE, STACKABLE_TRUST_STORE_PASSWORD,
+};
 
 #[derive(Snafu, Debug)]
 pub enum Error {

rust/crd/src/storage.rs

@@ -1,7 +1,7 @@
 use serde::{Deserialize, Serialize};
-use stackable_operator::k8s_openapi::apimachinery::pkg::api::resource::Quantity;
 use stackable_operator::{
     config::{fragment::Fragment, merge::Merge},
+    k8s_openapi::apimachinery::pkg::api::resource::Quantity,
     schemars::{self, JsonSchema},
 };
 

rust/crd/src/tls.rs

@@ -31,9 +31,10 @@ pub fn tls_default() -> Option<String> {
 
 #[cfg(test)]
 mod tests {
-    use crate::{tests::deserialize_yaml_str, tls::DruidTls, DruidClusterConfig};
     use indoc::formatdoc;
 
+    use crate::{tests::deserialize_yaml_str, tls::DruidTls, DruidClusterConfig};
+
     const BASE_DRUID_CONFIGURATION: &str = r#"
 deepStorage:
   hdfs:

rust/operator-binary/src/authentication/ldap.rs

@@ -1,15 +1,14 @@
 use std::collections::BTreeMap;
 
 use snafu::ResultExt;
+use stackable_druid_crd::security::{
+    add_cert_to_trust_store_cmd, STACKABLE_TLS_DIR, TLS_STORE_PASSWORD,
+};
 use stackable_operator::{
     builder::pod::{container::ContainerBuilder, PodBuilder},
     commons::authentication::ldap::AuthenticationProvider,
 };
 
-use stackable_druid_crd::security::{
-    add_cert_to_trust_store_cmd, STACKABLE_TLS_DIR, TLS_STORE_PASSWORD,
-};
-
 use crate::authentication::{
     AddLdapVolumesSnafu, ConstructLdapEndpointUrlSnafu, Error, MissingLdapBindCredentialsSnafu,
 };

rust/operator-binary/src/discovery.rs

@@ -1,8 +1,6 @@
 //! Discovery for Druid.  We make Druid discoverable by putting a connection string to the router service
 //! inside a config map.  We only provide a connection string to the router service, since it serves as
 //! a gateway to the cluster for client queries.
-use crate::DRUID_CONTROLLER_NAME;
-
 use snafu::{OptionExt, ResultExt, Snafu};
 use stackable_druid_crd::{
     build_recommended_labels, security::DruidTlsSecurity, DruidCluster, DruidRole,
@@ -15,6 +13,8 @@ use stackable_operator::{
     utils::cluster_info::KubernetesClusterInfo,
 };
 
+use crate::DRUID_CONTROLLER_NAME;
+
 #[derive(Snafu, Debug)]
 pub enum Error {
     #[snafu(display("object {} is missing metadata to build owner reference", druid))]