Skip to content

Commit 8c80948

Browse files
committed
fix: consolidate coordinator role extraction
1 parent a8af627 commit 8c80948

1 file changed

Lines changed: 6 additions & 29 deletions

File tree

  • rust/operator-binary/src/crd

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

Lines changed: 6 additions & 29 deletions
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ use stackable_operator::{
2828
kube::{CustomResource, ResourceExt},
2929
memory::{BinaryMultiple, MemoryQuantity},
3030
product_logging::{self, spec::Logging},
31-
role_utils::{CommonConfiguration, GenericRoleConfig, Role, RoleGroup},
31+
role_utils::{GenericRoleConfig, Role},
3232
schemars::{self, JsonSchema},
3333
shared::time::Duration,
3434
status::condition::{ClusterCondition, HasStatusCondition},
@@ -581,37 +581,14 @@ impl v1alpha1::TrinoCluster {
581581
}
582582
}
583583

584+
/// Converts the coordinator role (which carries the coordinator-specific `role_config`) into the
585+
/// generic [`TrinoRoleType`]. Only the `role_config` type parameter differs between the two; the
586+
/// `config` and `role_groups` carry over unchanged.
584587
fn extract_role_from_coordinator_config(fragment: TrinoCoordinatorRoleType) -> TrinoRoleType {
585588
Role {
586-
config: CommonConfiguration {
587-
config: fragment.config.config,
588-
config_overrides: fragment.config.config_overrides,
589-
env_overrides: fragment.config.env_overrides,
590-
cli_overrides: fragment.config.cli_overrides,
591-
pod_overrides: fragment.config.pod_overrides,
592-
product_specific_common_config: fragment.config.product_specific_common_config,
593-
},
589+
config: fragment.config,
594590
role_config: fragment.role_config.common,
595-
role_groups: fragment
596-
.role_groups
597-
.into_iter()
598-
.map(|(k, v)| {
599-
(
600-
k,
601-
RoleGroup {
602-
config: CommonConfiguration {
603-
config: v.config.config,
604-
config_overrides: v.config.config_overrides,
605-
env_overrides: v.config.env_overrides,
606-
cli_overrides: v.config.cli_overrides,
607-
pod_overrides: v.config.pod_overrides,
608-
product_specific_common_config: v.config.product_specific_common_config,
609-
},
610-
replicas: v.replicas,
611-
},
612-
)
613-
})
614-
.collect(),
591+
role_groups: fragment.role_groups,
615592
}
616593
}
617594

0 commit comments

Comments
 (0)