chore: Apply formatting

Author: Techassi

rust/crd/src/affinity.rs

@@ -28,10 +28,9 @@ pub fn get_affinity(cluster_name: &str, role: &HdfsRole) -> StackableAffinityFra
 
 #[cfg(test)]
 mod test {
-    use rstest::rstest;
     use std::collections::BTreeMap;
 
-    use crate::{HdfsCluster, HdfsRole};
+    use rstest::rstest;
     use stackable_operator::{
         commons::affinity::StackableAffinity,
         k8s_openapi::{
@@ -42,6 +41,8 @@ mod test {
         },
     };
 
+    use crate::{HdfsCluster, HdfsRole};
+
     #[rstest]
     #[case(HdfsRole::JournalNode)]
     #[case(HdfsRole::NameNode)]

rust/crd/src/lib.rs

@@ -11,6 +11,8 @@ use product_config::types::PropertyNameKind;
 use security::AuthorizationConfig;
 use serde::{Deserialize, Serialize};
 use snafu::{OptionExt, ResultExt, Snafu};
+#[cfg(doc)]
+use stackable_operator::commons::listener::ListenerClass;
 use stackable_operator::{
     commons::{
         affinity::StackableAffinity,
@@ -58,9 +60,6 @@ use crate::{
     },
 };
 
-#[cfg(doc)]
-use stackable_operator::commons::listener::ListenerClass;
-
 pub mod affinity;
 pub mod constants;
 pub mod security;
@@ -1492,13 +1491,13 @@ where
 
 #[cfg(test)]
 mod test {
-    use crate::storage::HdfsStorageType;
-
-    use super::{HdfsCluster, HdfsRole};
     use stackable_operator::k8s_openapi::{
         api::core::v1::ResourceRequirements, apimachinery::pkg::api::resource::Quantity,
     };
 
+    use super::{HdfsCluster, HdfsRole};
+    use crate::storage::HdfsStorageType;
+
     #[test]
     pub fn test_pvc_rolegroup_from_yaml() {
         let cr = "

rust/crd/src/storage.rs

@@ -1,15 +1,18 @@
 use std::collections::BTreeMap;
 
-use crate::constants::*;
 use serde::{Deserialize, Serialize};
-use stackable_operator::config::merge::{Atomic, Merge};
 use stackable_operator::{
     commons::resources::PvcConfig,
-    config::fragment::Fragment,
+    config::{
+        fragment::Fragment,
+        merge::{Atomic, Merge},
+    },
     k8s_openapi::api::core::v1::PersistentVolumeClaim,
     schemars::{self, JsonSchema},
 };
 
+use crate::constants::*;
+
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[derive(Clone, Debug, Default, JsonSchema, PartialEq, Fragment)]
 #[fragment_attrs(
@@ -182,11 +185,10 @@ impl HdfsStorageType {
 mod test {
     use std::collections::BTreeMap;
 
-    use stackable_operator::k8s_openapi::api::core::v1::VolumeResourceRequirements;
     use stackable_operator::{
         commons::resources::PvcConfig,
         k8s_openapi::{
-            api::core::v1::PersistentVolumeClaimSpec,
+            api::core::v1::{PersistentVolumeClaimSpec, VolumeResourceRequirements},
             apimachinery::pkg::{api::resource::Quantity, apis::meta::v1::LabelSelector},
         },
     };

rust/operator-binary/src/config/jvm.rs

@@ -99,9 +99,8 @@ pub fn construct_role_specific_jvm_args(
 mod tests {
     use stackable_hdfs_crd::{constants::DEFAULT_NAME_NODE_METRICS_PORT, HdfsCluster};
 
-    use crate::container::ContainerConfig;
-
     use super::*;
+    use crate::container::ContainerConfig;
 
     #[test]
     fn test_global_jvm_args() {

rust/operator-binary/src/config/mod.rs

@@ -1,17 +1,20 @@
+use std::collections::BTreeMap;
+
 use product_config::writer::to_hadoop_xml;
-use stackable_hdfs_crd::constants::{
-    DEFAULT_JOURNAL_NODE_RPC_PORT, DEFAULT_NAME_NODE_HTTPS_PORT, DEFAULT_NAME_NODE_HTTP_PORT,
-    DEFAULT_NAME_NODE_RPC_PORT, DFS_DATANODE_DATA_DIR, DFS_HA_NAMENODES, DFS_JOURNALNODE_EDITS_DIR,
-    DFS_JOURNALNODE_RPC_ADDRESS, DFS_NAMENODE_HTTPS_ADDRESS, DFS_NAMENODE_HTTP_ADDRESS,
-    DFS_NAMENODE_NAME_DIR, DFS_NAMENODE_RPC_ADDRESS, DFS_NAMENODE_SHARED_EDITS_DIR,
-    DFS_NAME_SERVICES, DFS_REPLICATION, FS_DEFAULT_FS, HA_ZOOKEEPER_QUORUM,
-    JOURNALNODE_ROOT_DATA_DIR, NAMENODE_ROOT_DATA_DIR, SERVICE_PORT_NAME_HTTP,
-    SERVICE_PORT_NAME_HTTPS, SERVICE_PORT_NAME_RPC,
+use stackable_hdfs_crd::{
+    constants::{
+        DEFAULT_JOURNAL_NODE_RPC_PORT, DEFAULT_NAME_NODE_HTTPS_PORT, DEFAULT_NAME_NODE_HTTP_PORT,
+        DEFAULT_NAME_NODE_RPC_PORT, DFS_DATANODE_DATA_DIR, DFS_HA_NAMENODES,
+        DFS_JOURNALNODE_EDITS_DIR, DFS_JOURNALNODE_RPC_ADDRESS, DFS_NAMENODE_HTTPS_ADDRESS,
+        DFS_NAMENODE_HTTP_ADDRESS, DFS_NAMENODE_NAME_DIR, DFS_NAMENODE_RPC_ADDRESS,
+        DFS_NAMENODE_SHARED_EDITS_DIR, DFS_NAME_SERVICES, DFS_REPLICATION, FS_DEFAULT_FS,
+        HA_ZOOKEEPER_QUORUM, JOURNALNODE_ROOT_DATA_DIR, NAMENODE_ROOT_DATA_DIR,
+        SERVICE_PORT_NAME_HTTP, SERVICE_PORT_NAME_HTTPS, SERVICE_PORT_NAME_RPC,
+    },
+    storage::{DataNodeStorageConfig, DataNodeStorageConfigInnerType},
+    HdfsCluster, HdfsPodRef,
 };
-use stackable_hdfs_crd::storage::{DataNodeStorageConfig, DataNodeStorageConfigInnerType};
-use stackable_hdfs_crd::{HdfsCluster, HdfsPodRef};
 use stackable_operator::utils::cluster_info::KubernetesClusterInfo;
-use std::collections::BTreeMap;
 
 pub mod jvm;
 

rust/operator-binary/src/hdfs_clusterrolebinding_nodes_controller.rs

@@ -3,7 +3,6 @@ use stackable_hdfs_crd::{
     constants::{APP_NAME, FIELD_MANAGER_SCOPE},
     HdfsCluster,
 };
-use stackable_operator::kube::ResourceExt;
 use stackable_operator::{
     commons::rbac::build_rbac_resources,
     k8s_openapi::api::rbac::v1::{ClusterRoleBinding, Subject},
@@ -14,7 +13,7 @@ use stackable_operator::{
             reflector::{ObjectRef, Store},
             watcher,
         },
-        Api, Client,
+        Api, Client, ResourceExt,
     },
     kvp::Labels,
 };

rust/operator-binary/src/hdfs_controller.rs

@@ -10,6 +10,10 @@ use product_config::{
     ProductConfigManager,
 };
 use snafu::{OptionExt, ResultExt, Snafu};
+use stackable_hdfs_crd::{
+    constants::*, AnyNodeConfig, HdfsCluster, HdfsClusterStatus, HdfsPodRef, HdfsRole,
+    UpgradeState, UpgradeStateError,
+};
 use stackable_operator::{
     builder::{
         configmap::ConfigMapBuilder,
@@ -50,11 +54,6 @@ use stackable_operator::{
 };
 use strum::{EnumDiscriminants, IntoEnumIterator, IntoStaticStr};
 
-use stackable_hdfs_crd::{
-    constants::*, AnyNodeConfig, HdfsCluster, HdfsClusterStatus, HdfsPodRef, HdfsRole,
-    UpgradeState, UpgradeStateError,
-};
-
 use crate::{
     build_recommended_labels,
     config::{CoreSiteConfigBuilder, HdfsSiteConfigBuilder},

rust/operator-binary/src/operations/pdb.rs

@@ -85,9 +85,10 @@ fn max_unavailable_data_nodes(num_datanodes: u16, dfs_replication: u16) -> u16 {
 
 #[cfg(test)]
 mod test {
-    use super::*;
     use rstest::rstest;
 
+    use super::*;
+
     #[rstest]
     #[case(0, 0, 1)]
     #[case(0, 1, 1)]