enable prometheus endpoint

Author: razvan

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

@@ -12,7 +12,8 @@ use crate::crd::{
         DFS_NAMENODE_HTTP_ADDRESS, DFS_NAMENODE_HTTPS_ADDRESS, DFS_NAMENODE_NAME_DIR,
         DFS_NAMENODE_RPC_ADDRESS, DFS_NAMENODE_SHARED_EDITS_DIR, 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,
+        PROMETHEUS_ENDPOINT_ENABLED, SERVICE_PORT_NAME_HTTP, SERVICE_PORT_NAME_HTTPS,
+        SERVICE_PORT_NAME_RPC,
     },
     storage::{DataNodeStorageConfig, DataNodeStorageConfigInnerType},
     v1alpha1,
@@ -264,6 +265,12 @@ impl CoreSiteConfigBuilder {
         let transformed_config = transform_for_product_config(&self.config);
         to_hadoop_xml(transformed_config.iter())
     }
+
+    pub fn enable_prometheus_endpoint(&mut self) -> &mut Self {
+        self.config
+            .insert(PROMETHEUS_ENDPOINT_ENABLED.to_string(), "true".to_string());
+        self
+    }
 }
 
 fn transform_for_product_config(

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

@@ -65,6 +65,7 @@ pub const DFS_HA_NAMENODES: &str = "dfs.ha.namenodes";
 // core-site.xml
 pub const FS_DEFAULT_FS: &str = "fs.defaultFS";
 pub const HA_ZOOKEEPER_QUORUM: &str = "ha.zookeeper.quorum";
+pub const PROMETHEUS_ENDPOINT_ENABLED: &str = "hadoop.prometheus.endpoint.enabled";
 
 pub const STACKABLE_ROOT_DATA_DIR: &str = "/stackable/data";
 pub const NAMENODE_ROOT_DATA_DIR: &str = "/stackable/data/namenode";

rust/operator-binary/src/hdfs_controller.rs

@@ -682,7 +682,8 @@ fn rolegroup_config_map(
                     .fs_default_fs()
                     .ha_zookeeper_quorum()
                     .security_config(hdfs, cluster_info)
-                    .context(BuildSecurityConfigSnafu)?;
+                    .context(BuildSecurityConfigSnafu)?
+                    .enable_prometheus_endpoint();
                 if let Some(hdfs_opa_config) = hdfs_opa_config {
                     hdfs_opa_config.add_core_site_config(&mut core_site);
                 }