chore: Update to stackable-operator 0.95.0 (#971)

* chore: Update to stackable-operator 0.95.0

* regenerate nix

* use upstream tag

* Update nix stuff

* In tests use expect over unwrap

Author: sbernauer

Cargo.lock

@@ -11,7 +11,7 @@ repository = "https://github.com/stackabletech/zookeeper-operator"
 
 [workspace.dependencies]
 product-config = { git = "https://github.com/stackabletech/product-config.git", tag = "0.7.0" }
-stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", features = ["telemetry", "versioned"], tag = "stackable-operator-0.94.0" }
+stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", features = ["telemetry", "versioned"], tag = "stackable-operator-0.95.0" }
 
 anyhow = "1.0"
 built = { version = "0.8", features = ["chrono", "git2"] }
@@ -31,7 +31,7 @@ tokio = { version = "1.40", features = ["full"] }
 tokio-zookeeper = "0.4"
 tracing = "0.1"
 
-#[patch."https://github.com/stackabletech/operator-rs"]
+# [patch."https://github.com/stackabletech/operator-rs"]
 # stackable-operator = { git = "https://github.com/stackabletech//operator-rs.git", branch = "main" }
 
 [patch.crates-io]

Cargo.nix

@@ -33,8 +33,9 @@ fn construct_jvm_args(
     zk: &ZookeeperCluster,
     role: &Role<ZookeeperConfigFragment, ZookeeperServerRoleConfig, JavaCommonConfig>,
     role_group: &str,
+    product_version: &str,
 ) -> Result<Vec<String>, Error> {
-    let logging_framework = zk.logging_framework();
+    let logging_framework = zk.logging_framework(product_version);
 
     let jvm_args = vec![
         format!("-Djava.security.properties={STACKABLE_CONFIG_DIR}/{JVM_SECURITY_PROPERTIES_FILE}"),
@@ -67,8 +68,9 @@ pub fn construct_non_heap_jvm_args(
     zk: &ZookeeperCluster,
     role: &Role<ZookeeperConfigFragment, ZookeeperServerRoleConfig, JavaCommonConfig>,
     role_group: &str,
+    product_version: &str,
 ) -> Result<String, Error> {
-    let mut jvm_args = construct_jvm_args(zk, role, role_group)?;
+    let mut jvm_args = construct_jvm_args(zk, role, role_group, product_version)?;
     jvm_args.retain(|arg| !is_heap_jvm_argument(arg));
 
     Ok(jvm_args.join(" "))
@@ -122,8 +124,15 @@ mod tests {
                 replicas: 1
         "#;
         let (zookeeper, merged_config, role, rolegroup) = construct_boilerplate(input);
-        let non_heap_jvm_args = construct_non_heap_jvm_args(&zookeeper, &role, &rolegroup).unwrap();
-        let zk_server_heap_env = construct_zk_server_heap_env(&merged_config).unwrap();
+        let non_heap_jvm_args = construct_non_heap_jvm_args(
+            &zookeeper,
+            &role,
+            &rolegroup,
+            zookeeper.spec.image.product_version(),
+        )
+        .expect("test: function must pass");
+        let zk_server_heap_env =
+            construct_zk_server_heap_env(&merged_config).expect("test: function must pass");
 
         assert_eq!(
             non_heap_jvm_args,
@@ -167,8 +176,15 @@ mod tests {
                     - -Dhttps.proxyPort=1234
         "#;
         let (zookeeper, merged_config, role, rolegroup) = construct_boilerplate(input);
-        let non_heap_jvm_args = construct_non_heap_jvm_args(&zookeeper, &role, &rolegroup).unwrap();
-        let zk_server_heap_env = construct_zk_server_heap_env(&merged_config).unwrap();
+        let non_heap_jvm_args = construct_non_heap_jvm_args(
+            &zookeeper,
+            &role,
+            &rolegroup,
+            zookeeper.spec.image.product_version(),
+        )
+        .expect("test: function must pass");
+        let zk_server_heap_env =
+            construct_zk_server_heap_env(&merged_config).expect("test: function must pass");
 
         assert_eq!(
             non_heap_jvm_args,
@@ -197,8 +213,12 @@ mod tests {
         let rolegroup_ref = zookeeper.server_rolegroup_ref("default");
         let merged_config = zookeeper
             .merged_config(&zookeeper_role, &rolegroup_ref)
-            .unwrap();
-        let role = zookeeper.spec.servers.clone().unwrap();
+            .expect("test: merged config can be created");
+        let role = zookeeper
+            .spec
+            .servers
+            .clone()
+            .expect("test: server role is defined in the ZookeeperCluster");
 
         (zookeeper, merged_config, role, "default".to_owned())
     }

Cargo.toml

@@ -27,8 +27,8 @@ use stackable_operator::{
     product_logging::{self, spec::Logging},
     role_utils::{GenericRoleConfig, JavaCommonConfig, Role, RoleGroup, RoleGroupRef},
     schemars::{self, JsonSchema},
+    shared::time::Duration,
     status::condition::{ClusterCondition, HasStatusCondition},
-    time::Duration,
     utils::cluster_info::KubernetesClusterInfo,
     versioned::versioned,
 };
@@ -88,10 +88,6 @@ pub const DOCKER_IMAGE_BASE_NAME: &str = "zookeeper";
 const DEFAULT_SERVER_GRACEFUL_SHUTDOWN_TIMEOUT: Duration = Duration::from_minutes_unchecked(2);
 pub const DEFAULT_LISTENER_CLASS: &str = "cluster-internal";
 
-mod built_info {
-    pub const CARGO_PKG_VERSION: &str = env!("CARGO_PKG_VERSION");
-}
-
 #[derive(Snafu, Debug)]
 pub enum Error {
     #[snafu(display("object has no namespace associated"))]
@@ -520,22 +516,14 @@ impl ZookeeperPodRef {
 }
 
 impl v1alpha1::ZookeeperCluster {
-    pub fn logging_framework(&self) -> LoggingFramework {
-        let version = self
-            .spec
-            .image
-            .resolve(
-                DOCKER_IMAGE_BASE_NAME,
-                crate::crd::built_info::CARGO_PKG_VERSION,
-            )
-            .product_version;
+    pub fn logging_framework(&self, product_version: &str) -> LoggingFramework {
         let zookeeper_versions_with_log4j = [
             "1.", "2.", "3.0.", "3.1.", "3.2.", "3.3.", "3.4.", "3.5.", "3.6.", "3.7.",
         ];
 
         if zookeeper_versions_with_log4j
             .into_iter()
-            .any(|prefix| version.starts_with(prefix))
+            .any(|prefix| product_version.starts_with(prefix))
         {
             LoggingFramework::LOG4J
         } else {

crate-hashes.json

@@ -22,7 +22,7 @@ use stackable_operator::{
     client::Client,
     crd::authentication::core,
     k8s_openapi::api::core::v1::Volume,
-    time::Duration,
+    shared::time::Duration,
 };
 
 use crate::{

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

@@ -104,7 +104,7 @@ pub fn build_discovery_configmap(
                 .with_recommended_labels(build_recommended_labels(
                     owner,
                     controller_name,
-                    &resolved_product_image.app_version_label,
+                    &resolved_product_image.app_version_label_value,
                     &ZookeeperRole::Server.to_string(),
                     "discovery",
                 ))

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

@@ -62,7 +62,7 @@ pub fn build_role_listener(
             .with_recommended_labels(build_recommended_labels(
                 zk,
                 ZK_CONTROLLER_NAME,
-                &resolved_product_image.app_version_label,
+                &resolved_product_image.app_version_label_value,
                 &zk_role.to_string(),
                 "none", // TODO (@NickLarsenNZ): update build_recommended_labels to have an optional role_group
             ))

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

@@ -68,15 +68,15 @@ async fn main() -> anyhow::Result<()> {
         Command::Run(ProductOperatorRun {
             product_config,
             watch_namespace,
-            telemetry_arguments,
-            cluster_info_opts,
+            operator_environment: _,
+            telemetry,
+            cluster_info,
         }) => {
             // NOTE (@NickLarsenNZ): Before stackable-telemetry was used:
             // - The console log level was set by `ZOOKEEPER_OPERATOR_LOG`, and is now `CONSOLE_LOG` (when using Tracing::pre_configured).
             // - The file log level was set by `ZOOKEEPER_OPERATOR_LOG`, and is now set via `FILE_LOG` (when using Tracing::pre_configured).
             // - The file log directory was set by `ZOOKEEPER_OPERATOR_LOG_DIRECTORY`, and is now set by `ROLLING_LOGS_DIR` (or via `--rolling-logs <DIRECTORY>`).
-            let _tracing_guard =
-                Tracing::pre_configured(built_info::PKG_NAME, telemetry_arguments).init()?;
+            let _tracing_guard = Tracing::pre_configured(built_info::PKG_NAME, telemetry).init()?;
 
             tracing::info!(
                 built_info.pkg_version = built_info::PKG_VERSION,
@@ -93,7 +93,7 @@ async fn main() -> anyhow::Result<()> {
             ])?;
             let client = stackable_operator::client::initialize_operator(
                 Some(OPERATOR_NAME.to_string()),
-                &cluster_info_opts,
+                &cluster_info,
             )
             .await?;