chore: Upgrade all dependencies

Author: siegfriedweber

Cargo.lock

@@ -10,7 +10,7 @@ edition = "2024"
 repository = "https://github.com/stackabletech/opensearch-operator"
 
 [workspace.dependencies]
-stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", features = ["telemetry", "versioned"], tag = "stackable-operator-0.93.2" }
+stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", features = ["telemetry", "versioned"], tag = "stackable-operator-0.97.0" }
 
 built = { version = "0.8.0", features = ["chrono", "git2"] }
 clap = "4.5"
@@ -21,7 +21,7 @@ serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 snafu = "0.8"
 strum = { version = "0.27", features = ["derive"] }
-tokio = { version = "1.45", features = ["full"] }
+tokio = { version = "1.47", features = ["full"] }
 tracing = "0.1"
 
 #[patch."https://github.com/stackabletech/operator-rs"]

Cargo.nix

@@ -12,6 +12,13 @@ rules:
     verbs:
       - list
       - watch
+  # For automatic cluster domain detection
+  - apiGroups:
+      - ""
+    resources:
+      - nodes/proxy
+    verbs:
+      - get
   - apiGroups:
       - ""
     resources:

Cargo.toml

@@ -5,7 +5,7 @@ use build::build;
 use snafu::{ResultExt, Snafu};
 use stackable_operator::{
     cluster_resources::ClusterResourceApplyStrategy,
-    commons::{affinity::StackableAffinity, product_image_selection::ProductImage},
+    commons::{affinity::StackableAffinity, product_image_selection::ResolvedProductImage},
     crd::listener::v1alpha1::Listener,
     k8s_openapi::api::{
         apps::v1::StatefulSet,
@@ -16,7 +16,7 @@ use stackable_operator::{
     kube::{Resource, api::ObjectMeta, core::DeserializeGuard, runtime::controller::Action},
     logging::controller::ReconcilerError,
     role_utils::GenericRoleConfig,
-    time::Duration,
+    shared::time::Duration,
 };
 use strum::{EnumDiscriminants, IntoStaticStr};
 use update_status::update_status;
@@ -128,7 +128,7 @@ pub struct ValidatedOpenSearchConfig {
 #[derive(Clone, Debug, PartialEq)]
 pub struct ValidatedCluster {
     metadata: ObjectMeta,
-    pub image: ProductImage,
+    pub image: ResolvedProductImage,
     pub product_version: ProductVersion,
     pub name: ClusterName,
     pub namespace: String,
@@ -140,7 +140,7 @@ pub struct ValidatedCluster {
 
 impl ValidatedCluster {
     pub fn new(
-        image: ProductImage,
+        image: ResolvedProductImage,
         product_version: ProductVersion,
         name: ClusterName,
         namespace: String,
@@ -318,10 +318,15 @@ struct KubernetesResources<T> {
 
 #[cfg(test)]
 mod tests {
-    use std::collections::{BTreeMap, HashMap};
+    use std::{
+        collections::{BTreeMap, HashMap},
+        str::FromStr,
+    };
 
     use stackable_operator::{
-        commons::affinity::StackableAffinity, k8s_openapi::api::core::v1::PodTemplateSpec,
+        commons::{affinity::StackableAffinity, product_image_selection::ResolvedProductImage},
+        k8s_openapi::api::core::v1::PodTemplateSpec,
+        kvp::LabelValue,
         role_utils::GenericRoleConfig,
     };
 
@@ -396,8 +401,14 @@ mod tests {
 
     fn validated_cluster() -> ValidatedCluster {
         ValidatedCluster::new(
-            serde_json::from_str(r#"{"productVersion": "3.1.0"}"#)
-                .expect("should be a valid ProductImage structure"),
+            ResolvedProductImage {
+                product_version: "3.1.0".to_owned(),
+                app_version_label_value: LabelValue::from_str("3.1.0-stackable0.0.0-dev")
+                    .expect("should be a valid label value"),
+                image: "oci.stackable.tech/sdp/opensearch:3.1.0-stackable0.0.0-dev".to_string(),
+                image_pull_policy: "Always".to_owned(),
+                pull_secrets: None,
+            },
             ProductVersion::from_str_unsafe("3.1.0"),
             ClusterName::from_str_unsafe("my-opensearch"),
             "default".to_owned(),

crate-hashes.json

@@ -46,11 +46,17 @@ pub fn build(names: &ContextNames, cluster: ValidatedCluster) -> KubernetesResou
 
 #[cfg(test)]
 mod tests {
-    use std::collections::{BTreeMap, HashMap};
+    use std::{
+        collections::{BTreeMap, HashMap},
+        str::FromStr,
+    };
 
     use stackable_operator::{
-        commons::affinity::StackableAffinity, k8s_openapi::api::core::v1::PodTemplateSpec,
-        kube::Resource, role_utils::GenericRoleConfig,
+        commons::{affinity::StackableAffinity, product_image_selection::ResolvedProductImage},
+        k8s_openapi::api::core::v1::PodTemplateSpec,
+        kube::Resource,
+        kvp::LabelValue,
+        role_utils::GenericRoleConfig,
     };
 
     use super::build;
@@ -137,8 +143,14 @@ mod tests {
 
     fn validated_cluster() -> ValidatedCluster {
         ValidatedCluster::new(
-            serde_json::from_str(r#"{"productVersion": "3.1.0"}"#)
-                .expect("should be a valid ProductImage structure"),
+            ResolvedProductImage {
+                product_version: "3.1.0".to_owned(),
+                app_version_label_value: LabelValue::from_str("3.1.0-stackable0.0.0-dev")
+                    .expect("should be a valid label value"),
+                image: "oci.stackable.tech/sdp/opensearch:3.1.0-stackable0.0.0-dev".to_string(),
+                image_pull_policy: "Always".to_owned(),
+                pull_secrets: None,
+            },
             ProductVersion::from_str_unsafe("3.1.0"),
             ClusterName::from_str_unsafe("my-opensearch"),
             "default".to_owned(),

deploy/helm/opensearch-operator/templates/roles.yaml

@@ -242,10 +242,12 @@ mod tests {
 
     use stackable_operator::{
         commons::{
-            affinity::StackableAffinity, product_image_selection::ProductImage,
+            affinity::StackableAffinity,
+            product_image_selection::{ProductImage, ResolvedProductImage},
             resources::Resources,
         },
         k8s_openapi::api::core::v1::PodTemplateSpec,
+        kvp::LabelValue,
         role_utils::GenericRoleConfig,
     };
 
@@ -300,7 +302,14 @@ mod tests {
         };
 
         let cluster = ValidatedCluster::new(
-            image.clone(),
+            ResolvedProductImage {
+                product_version: "3.1.0".to_owned(),
+                app_version_label_value: LabelValue::from_str("3.1.0-stackable0.0.0-dev")
+                    .expect("should be a valid label value"),
+                image: "oci.stackable.tech/sdp/opensearch:3.1.0-stackable0.0.0-dev".to_string(),
+                image_pull_policy: "Always".to_owned(),
+                pull_secrets: None,
+            },
             ProductVersion::from_str_unsafe(image.product_version()),
             ClusterName::from_str_unsafe("my-opensearch-cluster"),
             "default".to_owned(),

rust/operator-binary/src/controller.rs

@@ -197,15 +197,20 @@ impl<'a> RoleBuilder<'a> {
 
 #[cfg(test)]
 mod tests {
-    use std::collections::{BTreeMap, HashMap};
+    use std::{
+        collections::{BTreeMap, HashMap},
+        str::FromStr,
+    };
 
     use serde_json::json;
     use stackable_operator::{
         commons::{
-            affinity::StackableAffinity, product_image_selection::ProductImage,
+            affinity::StackableAffinity,
+            product_image_selection::{ProductImage, ResolvedProductImage},
             resources::Resources,
         },
         k8s_openapi::api::core::v1::PodTemplateSpec,
+        kvp::LabelValue,
         role_utils::GenericRoleConfig,
     };
 
@@ -255,7 +260,14 @@ mod tests {
         };
 
         let cluster = ValidatedCluster::new(
-            image.clone(),
+            ResolvedProductImage {
+                product_version: "3.1.0".to_owned(),
+                app_version_label_value: LabelValue::from_str("3.1.0-stackable0.0.0-dev")
+                    .expect("should be a valid label value"),
+                image: "oci.stackable.tech/sdp/opensearch:3.1.0-stackable0.0.0-dev".to_string(),
+                image_pull_policy: "Always".to_owned(),
+                pull_secrets: None,
+            },
             ProductVersion::from_str_unsafe(image.product_version()),
             ClusterName::from_str_unsafe("my-opensearch-cluster"),
             "default".to_owned(),

rust/operator-binary/src/controller/build.rs

@@ -245,11 +245,6 @@ impl<'a> RoleGroupBuilder<'a> {
     }
 
     fn build_container(&self, role_group_config: &OpenSearchRoleGroupConfig) -> Container {
-        let product_image = self
-            .cluster
-            .image
-            .resolve("opensearch", crate::built_info::PKG_VERSION);
-
         // Probe values taken from the official Helm chart
         let startup_probe = Probe {
             failure_threshold: Some(30),
@@ -289,7 +284,7 @@ impl<'a> RoleGroupBuilder<'a> {
 
         ContainerBuilder::new("opensearch")
             .expect("should be a valid container name")
-            .image_from_product_image(&product_image)
+            .image_from_product_image(&self.cluster.image)
             .command(vec![format!(
                 "{opensearch_home}/opensearch-docker-entrypoint.sh"
             )])
@@ -483,15 +478,19 @@ impl<'a> RoleGroupBuilder<'a> {
 
 #[cfg(test)]
 mod tests {
-    use std::collections::{BTreeMap, HashMap};
+    use std::{
+        collections::{BTreeMap, HashMap},
+        str::FromStr,
+    };
 
     use serde_json::json;
     use stackable_operator::{
         commons::{
-            affinity::StackableAffinity, product_image_selection::ProductImage,
+            affinity::StackableAffinity, product_image_selection::ResolvedProductImage,
             resources::Resources,
         },
         k8s_openapi::api::core::v1::PodTemplateSpec,
+        kvp::LabelValue,
         role_utils::GenericRoleConfig,
     };
     use strum::IntoEnumIterator;
@@ -517,8 +516,14 @@ mod tests {
     }
 
     fn validated_cluster() -> ValidatedCluster {
-        let image: ProductImage = serde_json::from_str(r#"{"productVersion": "3.1.0"}"#)
-            .expect("should be a valid ProductImage");
+        let image = ResolvedProductImage {
+            product_version: "3.1.0".to_owned(),
+            app_version_label_value: LabelValue::from_str("3.1.0-stackable0.0.0-dev")
+                .expect("should be a valid label value"),
+            image: "oci.stackable.tech/sdp/opensearch:3.1.0-stackable0.0.0-dev".to_string(),
+            image_pull_policy: "Always".to_owned(),
+            pull_secrets: None,
+        };
 
         let role_group_config = OpenSearchRoleGroupConfig {
             replicas: 1,
@@ -543,7 +548,7 @@ mod tests {
 
         ValidatedCluster::new(
             image.clone(),
-            ProductVersion::from_str_unsafe(image.product_version()),
+            ProductVersion::from_str_unsafe(&image.product_version),
             ClusterName::from_str_unsafe("my-opensearch-cluster"),
             "default".to_owned(),
             "0b1e30e6-326e-4c1a-868d-ad6598b49e8b".to_owned(),