chore: rustfmt

Author: dervoeti

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

@@ -95,8 +95,12 @@ pub fn build_merged_jvm_config(
     // OPA Java SDK.
     if let Some(authz_config) = authorization_config {
         if authz_config.has_opa_tls() {
-            jvm_args.push(format!("-Djavax.net.ssl.trustStore={STACKABLE_SERVER_TLS_DIR}/truststore.p12"));
-            jvm_args.push(format!("-Djavax.net.ssl.trustStorePassword={STACKABLE_TLS_STORE_PASSWORD}"));
+            jvm_args.push(format!(
+                "-Djavax.net.ssl.trustStore={STACKABLE_SERVER_TLS_DIR}/truststore.p12"
+            ));
+            jvm_args.push(format!(
+                "-Djavax.net.ssl.trustStorePassword={STACKABLE_TLS_STORE_PASSWORD}"
+            ));
             jvm_args.push("-Djavax.net.ssl.trustStoreType=pkcs12".to_owned());
         }
     }

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

@@ -130,7 +130,8 @@ pub fn build_bootstrap_conf(
     bootstrap.extend(graceful_shutdown_config_properties(merged_config));
 
     let merged_jvm_config =
-        build_merged_jvm_config(merged_config, role, role_group, authorization_config).context(InvalidJVMConfigSnafu)?;
+        build_merged_jvm_config(merged_config, role, role_group, authorization_config)
+            .context(InvalidJVMConfigSnafu)?;
 
     for (index, argument) in merged_jvm_config
         .effective_jvm_config_after_merging()

rust/operator-binary/src/controller.rs

@@ -1408,16 +1408,21 @@ async fn build_node_rolegroup_statefulset(
         .add_empty_dir_volume(TRUSTSTORE_VOLUME_NAME, None)
         .context(AddVolumeSnafu)?;
 
-    if let NifiAuthorizationConfig::Opa { secret_class: Some(secret_class), .. } = authorization_config
+    if let NifiAuthorizationConfig::Opa {
+        secret_class: Some(secret_class),
+        ..
+    } = authorization_config
     {
         pod_builder
-            .add_volume(VolumeBuilder::new(OPA_TLS_VOLUME_NAME)
-            .ephemeral(
-                SecretOperatorVolumeSourceBuilder::new(secret_class)
-                    .build()
-                    .context(OpaTlsCertSecretClassVolumeBuildSnafu)?,
+            .add_volume(
+                VolumeBuilder::new(OPA_TLS_VOLUME_NAME)
+                    .ephemeral(
+                        SecretOperatorVolumeSourceBuilder::new(secret_class)
+                            .build()
+                            .context(OpaTlsCertSecretClassVolumeBuildSnafu)?,
+                    )
+                    .build(),
             )
-            .build())
             .context(AddVolumeSnafu)?;
     }
 

rust/operator-binary/src/security/authorization.rs

@@ -61,7 +61,10 @@ impl NifiAuthorizationConfig {
 
                     NifiAuthorizationConfig::Opa {
                         configmap_name,
-                        cache_entry_time_to_live_secs: opa_config.cache.entry_time_to_live.as_secs(),
+                        cache_entry_time_to_live_secs: opa_config
+                            .cache
+                            .entry_time_to_live
+                            .as_secs(),
                         cache_max_entries: opa_config.cache.max_entries,
                         secret_class,
                     }
@@ -188,6 +191,12 @@ impl NifiAuthorizationConfig {
     }
 
     pub fn has_opa_tls(&self) -> bool {
-        matches!(self, NifiAuthorizationConfig::Opa { secret_class: Some(_), .. })
+        matches!(
+            self,
+            NifiAuthorizationConfig::Opa {
+                secret_class: Some(_),
+                ..
+            }
+        )
     }
 }