feat: Support dynamic image repositories

CHANGELOG.md

@@ -2,16 +2,21 @@
 
 ## [Unreleased]
 
+### Added
+
+- BREAKING: Add required CLI argument and env var to set the image repository used to construct final product image names: `IMAGE_REPOSITORY` (`--image-repository`), eg. `oci.example.org/my/namespace` ([#752]).
+
 ### Changed
 
-- Document Helm deployed RBAC permissions and remove unnecessary permissions ([#745]).
+- Document Helm deployed RBAC permissions and remove unnecessary permissions ([#745]).
 - BREAKING: `configOverrides` now only accepts the known config files (`hbase-site.xml`,
   `hbase-env.sh`, `ssl-server.xml`, `ssl-client.xml` and `security.properties`).
   Previously, arbitrary file names were silently accepted and ignored ([#751]).
-- Bump `stackable-operator` to 0.110.1 and snafu to 0.9 ([#751]).
+- Bump `stackable-operator` to 0.111.1 and snafu to 0.9 ([#751], [#752]).
 
 [#745]: https://github.com/stackabletech/hbase-operator/pull/745
 [#751]: https://github.com/stackabletech/hbase-operator/pull/751
+[#752]: https://github.com/stackabletech/hbase-operator/pull/752
 
 ## [26.3.0] - 2026-03-16
 

Cargo.toml

@@ -11,7 +11,7 @@ repository = "https://github.com/stackabletech/hbase-operator"
 
 [workspace.dependencies]
 product-config = { git = "https://github.com/stackabletech/product-config.git", tag = "0.8.0" }
-stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", tag = "stackable-operator-0.110.1", features = ["crds", "webhook"] }
+stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", tag = "stackable-operator-0.111.1", features = ["crds", "webhook"] }
 
 anyhow = "1.0"
 built = { version = "0.8", features = ["chrono", "git2"] }

extra/crds.yaml

@@ -145,8 +145,9 @@ spec:
                 properties:
                   custom:
                     description: |-
-                      Overwrite the docker image.
-                      Specify the full docker image name, e.g. `oci.stackable.tech/sdp/superset:1.4.1-stackable2.1.0`
+                      Provide a custom container image.
+
+                      Specify the full container image name, e.g. `oci.example.tech/namespace/superset:1.4.1-my-tag`
                     type: string
                   productVersion:
                     description: Version of the product, e.g. `1.4.1`.
@@ -173,14 +174,20 @@ spec:
                     nullable: true
                     type: array
                   repo:
-                    description: Name of the docker repo, e.g. `oci.stackable.tech/sdp`
+                    description: |-
+                      The repository on the container image registry where the container image is located, e.g.
+                      `oci.example.com/namespace`.
+
+                      If not specified, the operator will use the image registry provided via the operator
+                      environment options.
                     nullable: true
                     type: string
                   stackableVersion:
                     description: |-
                       Stackable version of the product, e.g. `23.4`, `23.4.1` or `0.0.0-dev`.
-                      If not specified, the operator will use its own version, e.g. `23.4.1`.
-                      When using a nightly operator or a pr version, it will use the nightly `0.0.0-dev` image.
+
+                      If not specified, the operator will use its own version, e.g. `23.4.1`. When using a nightly
+                      operator or a PR version, it will use the nightly `0.0.0-dev` image.
                     nullable: true
                     type: string
                 type: object

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

@@ -1371,8 +1371,11 @@ mod tests {
     use indoc::indoc;
     use product_config::{ProductConfigManager, types::PropertyNameKind};
     use rstest::rstest;
-    use stackable_operator::product_config_utils::{
-        transform_all_roles_to_config, validate_all_roles_and_groups_config,
+    use stackable_operator::{
+        product_config_utils::{
+            transform_all_roles_to_config, validate_all_roles_and_groups_config,
+        },
+        versioned::test_utils::RoundtripTestData,
     };
 
     use super::*;
@@ -1543,4 +1546,91 @@ spec:
             panic!("this shouldn't happen");
         };
     }
+
+    impl RoundtripTestData for v1alpha1::HbaseClusterSpec {
+        fn roundtrip_test_data() -> Vec<Self> {
+            stackable_operator::utils::yaml_from_str_singleton_map(indoc::indoc! {r#"
+              - image:
+                  productVersion: 2.6.4
+                  pullPolicy: IfNotPresent
+                clusterOperation:
+                  reconciliationPaused: false
+                  stopped: true
+                clusterConfig:
+                  hdfsConfigMapName: test-hdfs
+                  zookeeperConfigMapName: test-znode
+                  vectorAggregatorConfigMapName: vector-aggregator-discovery
+                  authentication:
+                    tlsSecretClass: my-tls
+                    kerberos:
+                      secretClass: my-kerberos
+                  authorization:
+                    opa:
+                      configMapName: opa
+                      package: hbase
+                masters:
+                  envOverrides:
+                    COMMON_VAR: role-value
+                    ROLE_VAR: role-value
+                  config:
+                    gracefulShutdownTimeout: 1m
+                    resources:
+                      cpu:
+                        min: 250m
+                        max: "1"
+                      memory:
+                        limit: 1Gi
+                    logging:
+                      enableVectorAgent: true
+                    listenerClass: cluster-internal
+                  configOverrides:
+                    hbase-site.xml:
+                      hbase.master.info.port: "16010"
+                  roleGroups:
+                    default:
+                      replicas: 2
+                      configOverrides:
+                        hbase-site.xml:
+                          hbase.master.info.port: "16011"
+                      envOverrides:
+                        COMMON_VAR: group-value
+                        GROUP_VAR: group-value
+                regionServers:
+                  config:
+                    gracefulShutdownTimeout: 2m
+                    resources:
+                      cpu:
+                        min: 250m
+                        max: "2"
+                      memory:
+                        limit: 2Gi
+                    logging:
+                      enableVectorAgent: true
+                    regionMover:
+                      runBeforeShutdown: true
+                      ack: true
+                      maxThreads: 1
+                    listenerClass: cluster-internal
+                  roleGroups:
+                    default:
+                      replicas: 3
+                restServers:
+                  config:
+                    gracefulShutdownTimeout: 1m
+                    resources:
+                      cpu:
+                        min: 100m
+                        max: "1"
+                      memory:
+                        limit: 1Gi
+                    logging:
+                      enableVectorAgent: true
+                    listenerClass: cluster-internal
+                  roleGroups:
+                    default:
+                      replicas: 1
+        "#})
+            .expect("Failed to parse HbaseClusterSpec YAML")
+        }
+    }
 }