refactor: rename kafka_controller.rs -> controller.rs

Author: maltesander

…/operator-binary/src/kafka_controller.rs rust/operator-binary/src/controller.rsrust/operator-binary/src/kafka_controller.rs renamed to rust/operator-binary/src/controller.rs rust/operator-binary/src/kafka_controller.rs renamed to rust/operator-binary/src/controller.rs

@@ -10,8 +10,8 @@ use stackable_operator::{
 };
 
 use crate::{
+    controller::KAFKA_CONTROLLER_NAME,
     crd::{role::KafkaRole, security::KafkaTlsSecurity, v1alpha1},
-    kafka_controller::KAFKA_CONTROLLER_NAME,
     utils::build_recommended_labels,
 };
 

rust/operator-binary/src/discovery.rs

@@ -35,15 +35,15 @@ use stackable_operator::{
 };
 
 use crate::{
+    controller::KAFKA_FULL_CONTROLLER_NAME,
     crd::{KafkaCluster, KafkaClusterVersion, OPERATOR_NAME, v1alpha1},
-    kafka_controller::KAFKA_FULL_CONTROLLER_NAME,
     webhooks::conversion::create_webhook_server,
 };
 
 mod config;
+mod controller;
 mod crd;
 mod discovery;
-mod kafka_controller;
 mod kerberos;
 mod operations;
 mod product_logging;
@@ -183,9 +183,9 @@ async fn main() -> anyhow::Result<()> {
                 )
                 .graceful_shutdown_on(sigterm_watcher.handle())
                 .run(
-                    kafka_controller::reconcile_kafka,
-                    kafka_controller::error_policy,
-                    Arc::new(kafka_controller::Ctx {
+                    controller::reconcile_kafka,
+                    controller::error_policy,
+                    Arc::new(controller::Ctx {
                         client: client.clone(),
                         operator_environment,
                         product_config,

rust/operator-binary/src/main.rs

@@ -5,8 +5,8 @@ use stackable_operator::{
 };
 
 use crate::{
+    controller::KAFKA_CONTROLLER_NAME,
     crd::{APP_NAME, OPERATOR_NAME, role::KafkaRole, v1alpha1},
-    kafka_controller::KAFKA_CONTROLLER_NAME,
 };
 
 #[derive(Snafu, Debug)]

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

@@ -14,6 +14,7 @@ use stackable_operator::{
 };
 
 use crate::{
+    controller::KAFKA_CONTROLLER_NAME,
     crd::{
         JVM_SECURITY_PROPERTIES_FILE, KafkaPodDescriptor, MetadataManager,
         STACKABLE_LISTENER_BOOTSTRAP_DIR, STACKABLE_LISTENER_BROKER_DIR,
@@ -26,7 +27,6 @@ use crate::{
         security::KafkaTlsSecurity,
         v1alpha1,
     },
-    kafka_controller::KAFKA_CONTROLLER_NAME,
     operations::graceful_shutdown::graceful_shutdown_config_properties,
     product_logging::extend_role_group_config_map,
     utils::build_recommended_labels,

rust/operator-binary/src/resource/configmap.rs

@@ -5,8 +5,8 @@ use stackable_operator::{
 };
 
 use crate::{
+    controller::KAFKA_CONTROLLER_NAME,
     crd::{role::broker::BrokerConfig, security::KafkaTlsSecurity, v1alpha1},
-    kafka_controller::KAFKA_CONTROLLER_NAME,
     utils::build_recommended_labels,
 };
 

rust/operator-binary/src/resource/listener.rs

@@ -8,8 +8,8 @@ use stackable_operator::{
 };
 
 use crate::{
+    controller::KAFKA_CONTROLLER_NAME,
     crd::{APP_NAME, METRICS_PORT, METRICS_PORT_NAME, security::KafkaTlsSecurity, v1alpha1},
-    kafka_controller::KAFKA_CONTROLLER_NAME,
     utils::build_recommended_labels,
 };
 

rust/operator-binary/src/resource/service.rs

@@ -48,6 +48,7 @@ use crate::{
         command::{broker_kafka_container_commands, controller_kafka_container_command},
         node_id_hasher::node_id_hash32_offset,
     },
+    controller::KAFKA_CONTROLLER_NAME,
     crd::{
         self, APP_NAME, KAFKA_HEAP_OPTS, LISTENER_BOOTSTRAP_VOLUME_NAME,
         LISTENER_BROKER_VOLUME_NAME, LOG_DIRS_VOLUME_NAME, METRICS_PORT, METRICS_PORT_NAME,
@@ -60,7 +61,6 @@ use crate::{
         security::KafkaTlsSecurity,
         v1alpha1,
     },
-    kafka_controller::KAFKA_CONTROLLER_NAME,
     kerberos::add_kerberos_pod_config,
     operations::graceful_shutdown::add_graceful_shutdown_config,
     product_logging::{