chore: Format Rust code

Author: siegfriedweber

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

@@ -108,11 +108,7 @@ fn is_heap_jvm_argument(jvm_argument: &str) -> bool {
 #[cfg(test)]
 mod tests {
     use super::*;
-    use crate::crd::{
-        BrokerRole,
-        role::KafkaRole,
-        v1alpha1,
-    };
+    use crate::crd::{BrokerRole, role::KafkaRole, v1alpha1};
 
     #[test]
     fn test_construct_jvm_arguments_defaults() {
@@ -194,13 +190,7 @@ mod tests {
         assert_eq!(heap_jvm_args, "-Xms34406m -Xmx40000m");
     }
 
-    fn construct_boilerplate(
-        kafka_cluster: &str,
-    ) -> (
-        AnyConfig,
-        BrokerRole,
-        String,
-    ) {
+    fn construct_boilerplate(kafka_cluster: &str) -> (AnyConfig, BrokerRole, String) {
         let kafka: v1alpha1::KafkaCluster =
             serde_yaml::from_str(kafka_cluster).expect("illegal test input");
 

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

@@ -60,8 +60,10 @@ pub const STACKABLE_CONFIG_DIR: &str = "/stackable/config";
 pub const STACKABLE_KERBEROS_DIR: &str = "/stackable/kerberos";
 pub const STACKABLE_KERBEROS_KRB5_PATH: &str = "/stackable/kerberos/krb5.conf";
 
-pub type BrokerRole = Role<BrokerConfigFragment, KafkaConfigOverrides, GenericRoleConfig, JavaCommonConfig>;
-pub type ControllerRole = Role<ControllerConfigFragment, KafkaConfigOverrides, GenericRoleConfig, JavaCommonConfig>;
+pub type BrokerRole =
+    Role<BrokerConfigFragment, KafkaConfigOverrides, GenericRoleConfig, JavaCommonConfig>;
+pub type ControllerRole =
+    Role<ControllerConfigFragment, KafkaConfigOverrides, GenericRoleConfig, JavaCommonConfig>;
 
 #[derive(Clone, Debug, Default, Deserialize, JsonSchema, PartialEq, Serialize)]
 #[serde(rename_all = "camelCase")]
@@ -361,17 +363,13 @@ impl v1alpha1::KafkaCluster {
         }
     }
 
-    pub fn broker_role(
-        &self,
-    ) -> Result<&BrokerRole, Error> {
+    pub fn broker_role(&self) -> Result<&BrokerRole, Error> {
         self.spec.brokers.as_ref().context(MissingRoleSnafu {
             role: KafkaRole::Broker.to_string(),
         })
     }
 
-    pub fn controller_role(
-        &self,
-    ) -> Result<&ControllerRole, Error> {
+    pub fn controller_role(&self) -> Result<&ControllerRole, Error> {
         self.spec.controllers.as_ref().context(MissingRoleSnafu {
             role: KafkaRole::Controller.to_string(),
         })