chore: Apply formatting

Author: Techassi

rust/crd/src/affinity.rs

@@ -26,8 +26,6 @@ pub fn history_affinity(cluster_name: &str) -> StackableAffinityFragment {
 mod test {
     use std::collections::BTreeMap;
 
-    use crate::{constants::HISTORY_ROLE_NAME, history::SparkHistoryServer};
-
     use stackable_operator::{
         commons::affinity::StackableAffinity,
         k8s_openapi::{
@@ -38,6 +36,8 @@ mod test {
         role_utils::RoleGroupRef,
     };
 
+    use crate::{constants::HISTORY_ROLE_NAME, history::SparkHistoryServer};
+
     #[test]
     pub fn test_history_affinity_defaults() {
         let input = r#"

rust/crd/src/constants.rs

@@ -1,5 +1,4 @@
 use const_format::concatcp;
-
 use stackable_operator::memory::{BinaryMultiple, MemoryQuantity};
 
 pub const APP_NAME: &str = "spark-k8s";

rust/crd/src/history.rs

@@ -1,5 +1,4 @@
-use crate::logdir::ResolvedLogDir;
-use crate::{affinity::history_affinity, constants::*};
+use std::collections::{BTreeMap, HashMap};
 
 use product_config::{types::PropertyNameKind, ProductConfigManager};
 use serde::{Deserialize, Serialize};
@@ -29,9 +28,10 @@ use stackable_operator::{
     schemars::{self, JsonSchema},
     time::Duration,
 };
-use std::collections::{BTreeMap, HashMap};
 use strum::{Display, EnumIter};
 
+use crate::{affinity::history_affinity, constants::*, logdir::ResolvedLogDir};
+
 #[derive(Snafu, Debug)]
 pub enum Error {
     #[snafu(display("failed to transform configs"))]
@@ -477,15 +477,15 @@ impl Configuration for HistoryConfigFragment {
 
 #[cfg(test)]
 mod test {
-    use crate::logdir::S3LogDir;
-
-    use super::*;
     use indoc::indoc;
     use stackable_operator::commons::{
         s3::{ResolvedS3Bucket, ResolvedS3Connection},
         tls_verification::TlsClientDetails,
     };
 
+    use super::*;
+    use crate::logdir::S3LogDir;
+
     #[test]
     pub fn test_env_overrides() {
         let input = indoc! {r#"

rust/crd/src/lib.rs

@@ -7,15 +7,17 @@ pub mod logdir;
 pub mod roles;
 pub mod tlscerts;
 
-pub use crate::roles::*;
+use std::{
+    cmp::max,
+    collections::{BTreeMap, HashMap},
+};
+
 use constants::*;
 use history::LogFileDirectorySpec;
 use logdir::ResolvedLogDir;
 use product_config::{types::PropertyNameKind, ProductConfigManager};
 use serde::{Deserialize, Serialize};
 use snafu::{OptionExt, ResultExt, Snafu};
-use stackable_operator::role_utils::{GenericProductSpecificCommonConfig, GenericRoleConfig};
-use stackable_operator::time::Duration;
 use stackable_operator::{
     builder::pod::volume::{
         SecretFormat, SecretOperatorVolumeSourceBuilder, SecretOperatorVolumeSourceBuilderError,
@@ -42,14 +44,15 @@ use stackable_operator::{
         ValidatedRoleConfigByPropertyKind,
     },
     product_logging,
-    role_utils::{CommonConfiguration, Role, RoleGroup},
+    role_utils::{
+        CommonConfiguration, GenericProductSpecificCommonConfig, GenericRoleConfig, Role, RoleGroup,
+    },
     schemars::{self, JsonSchema},
+    time::Duration,
     utils::crds::raw_object_list_schema,
 };
-use std::{
-    cmp::max,
-    collections::{BTreeMap, HashMap},
-};
+
+pub use crate::roles::*;
 
 #[derive(Snafu, Debug)]
 pub enum Error {
@@ -1082,23 +1085,26 @@ where
 #[cfg(test)]
 mod tests {
 
-    use super::*;
+    use std::collections::{BTreeMap, HashMap};
 
-    use crate::{cores_from_quantity, resources_to_executor_props, RoleConfig};
-    use crate::{resources_to_driver_props, SparkApplication};
-    use crate::{Quantity, SparkStorageConfig};
+    use indoc::indoc;
     use product_config::{types::PropertyNameKind, ProductConfigManager};
-    use stackable_operator::commons::affinity::StackableAffinity;
-    use stackable_operator::commons::resources::{
-        CpuLimits, MemoryLimits, NoRuntimeLimits, Resources,
+    use rstest::rstest;
+    use stackable_operator::{
+        commons::{
+            affinity::StackableAffinity,
+            resources::{CpuLimits, MemoryLimits, NoRuntimeLimits, Resources},
+        },
+        product_config_utils::ValidatedRoleConfigByPropertyKind,
+        product_logging::spec::Logging,
+        time::Duration,
     };
-    use stackable_operator::product_config_utils::ValidatedRoleConfigByPropertyKind;
-    use stackable_operator::product_logging::spec::Logging;
 
-    use indoc::indoc;
-    use rstest::rstest;
-    use stackable_operator::time::Duration;
-    use std::collections::{BTreeMap, HashMap};
+    use super::*;
+    use crate::{
+        cores_from_quantity, resources_to_driver_props, resources_to_executor_props, Quantity,
+        RoleConfig, SparkApplication, SparkStorageConfig,
+    };
 
     #[test]
     fn test_default_resource_limits() {

rust/crd/src/logdir.rs

@@ -1,11 +1,6 @@
-use crate::{
-    constants::*,
-    history::{
-        LogFileDirectorySpec::{self, S3},
-        S3LogFileDirectorySpec,
-    },
-    tlscerts,
-};
+use std::collections::BTreeMap;
+
+use snafu::{ResultExt, Snafu};
 use stackable_operator::{
     builder::pod::volume::{
         SecretFormat, SecretOperatorVolumeSourceBuilder, SecretOperatorVolumeSourceBuilderError,
@@ -18,11 +13,17 @@ use stackable_operator::{
     k8s_openapi::api::core::v1::{Volume, VolumeMount},
     time::Duration,
 };
-use std::collections::BTreeMap;
-
-use snafu::{ResultExt, Snafu};
 use strum::{EnumDiscriminants, IntoStaticStr};
 
+use crate::{
+    constants::*,
+    history::{
+        LogFileDirectorySpec::{self, S3},
+        S3LogFileDirectorySpec,
+    },
+    tlscerts,
+};
+
 #[derive(Snafu, Debug, EnumDiscriminants)]
 #[strum_discriminants(derive(IntoStaticStr))]
 #[allow(clippy::enum_variant_names)]

rust/crd/src/roles.rs

@@ -13,12 +13,9 @@
 //! each role is named "default". These roles are transparent to the user.
 //!
 //! The history server has its own role completely unrelated to this module.
-use crate::ResolvedLogDir;
 use std::{collections::BTreeMap, slice};
 
 use serde::{Deserialize, Serialize};
-
-use crate::SparkApplication;
 use stackable_operator::{
     commons::{
         affinity::StackableAffinity,
@@ -41,6 +38,8 @@ use stackable_operator::{
 };
 use strum::{Display, EnumIter};
 
+use crate::{ResolvedLogDir, SparkApplication};
+
 #[derive(Clone, Debug, Deserialize, Display, Eq, PartialEq, Serialize, JsonSchema)]
 #[strum(serialize_all = "kebab-case")]
 pub enum SparkApplicationRole {

rust/operator-binary/src/history/history_controller.rs

@@ -1,14 +1,19 @@
-use crate::history::operations::pdb::add_pdbs;
-use crate::product_logging::{self, resolve_vector_aggregator_address};
-use crate::Ctx;
+use std::{
+    collections::{BTreeMap, HashMap},
+    sync::Arc,
+};
+
 use product_config::{types::PropertyNameKind, writer::to_java_properties_string};
-use stackable_operator::kube::core::{error_boundary, DeserializeGuard};
+use snafu::{OptionExt, ResultExt, Snafu};
 use stackable_operator::{
     builder::{
         self,
         configmap::ConfigMapBuilder,
         meta::ObjectMetaBuilder,
-        pod::{container::ContainerBuilder, volume::VolumeBuilder, PodBuilder},
+        pod::{
+            container::ContainerBuilder, resources::ResourceRequirementsBuilder,
+            volume::VolumeBuilder, PodBuilder,
+        },
     },
     cluster_resources::{ClusterResourceApplyStrategy, ClusterResources},
     commons::product_image_selection::ResolvedProductImage,
@@ -21,12 +26,15 @@ use stackable_operator::{
             rbac::v1::{ClusterRole, RoleBinding, RoleRef, Subject},
         },
         apimachinery::pkg::apis::meta::v1::LabelSelector,
+        DeepMerge,
     },
     kube::{
+        core::{error_boundary, DeserializeGuard},
         runtime::{controller::Action, reflector::ObjectRef},
         Resource, ResourceExt,
     },
     kvp::{Label, Labels, ObjectLabels},
+    logging::controller::ReconcilerError,
     product_logging::{
         framework::{calculate_log_volume_size_limit, vector_container, LoggingError},
         spec::{
@@ -37,30 +45,28 @@ use stackable_operator::{
     role_utils::RoleGroupRef,
     time::Duration,
 };
-use stackable_spark_k8s_crd::constants::{METRICS_PORT, SPARK_ENV_SH_FILE_NAME};
-use stackable_spark_k8s_crd::logdir::ResolvedLogDir;
 use stackable_spark_k8s_crd::{
     constants::{
         ACCESS_KEY_ID, APP_NAME, HISTORY_CONTROLLER_NAME, HISTORY_ROLE_NAME,
-        JVM_SECURITY_PROPERTIES_FILE, MAX_SPARK_LOG_FILES_SIZE, OPERATOR_NAME, SECRET_ACCESS_KEY,
-        SPARK_CLUSTER_ROLE, SPARK_DEFAULTS_FILE_NAME, SPARK_IMAGE_BASE_NAME, SPARK_UID,
-        STACKABLE_TRUST_STORE, VOLUME_MOUNT_NAME_CONFIG, VOLUME_MOUNT_NAME_LOG,
-        VOLUME_MOUNT_NAME_LOG_CONFIG, VOLUME_MOUNT_PATH_CONFIG, VOLUME_MOUNT_PATH_LOG,
-        VOLUME_MOUNT_PATH_LOG_CONFIG,
+        JVM_SECURITY_PROPERTIES_FILE, MAX_SPARK_LOG_FILES_SIZE, METRICS_PORT, OPERATOR_NAME,
+        SECRET_ACCESS_KEY, SPARK_CLUSTER_ROLE, SPARK_DEFAULTS_FILE_NAME, SPARK_ENV_SH_FILE_NAME,
+        SPARK_IMAGE_BASE_NAME, SPARK_UID, STACKABLE_TRUST_STORE, VOLUME_MOUNT_NAME_CONFIG,
+        VOLUME_MOUNT_NAME_LOG, VOLUME_MOUNT_NAME_LOG_CONFIG, VOLUME_MOUNT_PATH_CONFIG,
+        VOLUME_MOUNT_PATH_LOG, VOLUME_MOUNT_PATH_LOG_CONFIG,
     },
     history,
     history::{HistoryConfig, SparkHistoryServer, SparkHistoryServerContainer},
+    logdir::ResolvedLogDir,
     tlscerts, to_spark_env_sh_string,
 };
-use std::collections::HashMap;
-use std::{collections::BTreeMap, sync::Arc};
-
-use snafu::{OptionExt, ResultExt, Snafu};
-use stackable_operator::builder::pod::resources::ResourceRequirementsBuilder;
-use stackable_operator::k8s_openapi::DeepMerge;
-use stackable_operator::logging::controller::ReconcilerError;
 use strum::{EnumDiscriminants, IntoStaticStr};
 
+use crate::{
+    history::operations::pdb::add_pdbs,
+    product_logging::{self, resolve_vector_aggregator_address},
+    Ctx,
+};
+
 #[derive(Snafu, Debug, EnumDiscriminants)]
 #[strum_discriminants(derive(IntoStaticStr))]
 #[allow(clippy::enum_variant_names)]

rust/operator-binary/src/main.rs

@@ -9,7 +9,6 @@ use clap::{crate_description, crate_version, Parser};
 use futures::{pin_mut, StreamExt};
 use history::history_controller;
 use product_config::ProductConfigManager;
-
 use stackable_operator::{
     cli::{Command, ProductOperatorRun},
     k8s_openapi::api::{
@@ -26,7 +25,6 @@ use stackable_operator::{
     logging::controller::report_controller_reconciled,
     CustomResourceExt,
 };
-
 use stackable_spark_k8s_crd::{
     constants::{
         HISTORY_FULL_CONTROLLER_NAME, OPERATOR_NAME, POD_DRIVER_FULL_CONTROLLER_NAME,

rust/operator-binary/src/pod_driver_controller.rs

@@ -1,17 +1,19 @@
+use std::sync::Arc;
+
+use snafu::{OptionExt, ResultExt, Snafu};
 use stackable_operator::{
     client::Client,
     k8s_openapi::api::core::v1::Pod,
-    kube::core::{error_boundary, DeserializeGuard},
-    kube::runtime::controller::Action,
+    kube::{
+        core::{error_boundary, DeserializeGuard},
+        runtime::controller::Action,
+    },
+    logging::controller::ReconcilerError,
     time::Duration,
 };
 use stackable_spark_k8s_crd::{
     constants::POD_DRIVER_CONTROLLER_NAME, SparkApplication, SparkApplicationStatus,
 };
-use std::sync::Arc;
-
-use snafu::{OptionExt, ResultExt, Snafu};
-use stackable_operator::logging::controller::ReconcilerError;
 use strum::{EnumDiscriminants, IntoStaticStr};
 
 const LABEL_NAME_INSTANCE: &str = "app.kubernetes.io/instance";