Skip to content

Commit 53073d6

Browse files
committed
move dereferenced fields to validated struct
1 parent 3f5b828 commit 53073d6

2 files changed

Lines changed: 14 additions & 5 deletions

File tree

rust/operator-binary/src/controller.rs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -441,10 +441,10 @@ pub async fn reconcile_druid(
441441
&rolegroup,
442442
rolegroup_config,
443443
&merged_rolegroup_config,
444-
&dereferenced_objects.zookeeper_connection_string,
445-
dereferenced_objects.opa_connection_string.as_deref(),
446-
dereferenced_objects.s3_connection.as_ref(),
447-
dereferenced_objects.deep_storage_bucket_name.as_deref(),
444+
&validated.zookeeper_connection_string,
445+
validated.opa_connection_string.as_deref(),
446+
validated.s3_connection.as_ref(),
447+
validated.deep_storage_bucket_name.as_deref(),
448448
&validated.druid_tls_security,
449449
&validated.druid_auth_config,
450450
)?;
@@ -455,7 +455,7 @@ pub async fn reconcile_druid(
455455
&rolegroup,
456456
rolegroup_config,
457457
&merged_rolegroup_config,
458-
dereferenced_objects.s3_connection.as_ref(),
458+
validated.s3_connection.as_ref(),
459459
&validated.druid_tls_security,
460460
&validated.druid_auth_config,
461461
&rbac_sa,

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

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@ use snafu::{ResultExt, Snafu};
88
use stackable_operator::{
99
cli::OperatorEnvironmentOptions,
1010
commons::product_image_selection::{self, ResolvedProductImage},
11+
crd::s3,
1112
product_config_utils::{
1213
ValidatedRoleConfigByPropertyKind, transform_all_roles_to_config,
1314
validate_all_roles_and_groups_config,
@@ -48,6 +49,10 @@ type Result<T, E = Error> = std::result::Result<T, E>;
4849

4950
/// Synchronous inputs the rest of `reconcile_druid` needs after dereferencing.
5051
pub struct ValidatedInputs {
52+
pub zookeeper_connection_string: String,
53+
pub opa_connection_string: Option<String>,
54+
pub s3_connection: Option<s3::v1alpha1::ConnectionSpec>,
55+
pub deep_storage_bucket_name: Option<String>,
5156
pub resolved_product_image: ResolvedProductImage,
5257
pub druid_tls_security: DruidTlsSecurity,
5358
pub druid_auth_config: Option<DruidAuthenticationConfig>,
@@ -93,6 +98,10 @@ pub fn validate(
9398
.context(InvalidProductConfigSnafu)?;
9499

95100
Ok(ValidatedInputs {
101+
zookeeper_connection_string: dereferenced_objects.zookeeper_connection_string.clone(),
102+
opa_connection_string: dereferenced_objects.opa_connection_string.clone(),
103+
s3_connection: dereferenced_objects.s3_connection.clone(),
104+
deep_storage_bucket_name: dereferenced_objects.deep_storage_bucket_name.clone(),
96105
resolved_product_image,
97106
druid_tls_security,
98107
druid_auth_config,

0 commit comments

Comments
 (0)