Skip to content

Commit 8072787

Browse files
committed
Moving headless name building in method
1 parent 67523a8 commit 8072787

2 files changed

Lines changed: 10 additions & 5 deletions

File tree

rust/operator-binary/src/controller.rs

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,7 @@ use crate::{
9797
STACKABLE_LOG_CONFIG_MOUNT_DIR, STACKABLE_LOG_CONFIG_MOUNT_DIR_NAME, STACKABLE_LOG_DIR,
9898
STACKABLE_LOG_DIR_NAME, v1alpha1,
9999
},
100-
discovery,
100+
discovery::{self, build_headless_listener_service_name},
101101
kerberos::{
102102
self, add_kerberos_pod_config, kerberos_config_properties,
103103
kerberos_container_start_commands,
@@ -770,7 +770,9 @@ fn build_rolegroup_service(
770770
Ok(Service {
771771
metadata: ObjectMetaBuilder::new()
772772
.name_and_namespace(hive)
773-
.name(format!("{name}-metrics", name = rolegroup.object_name()))
773+
.name(build_headless_listener_service_name(
774+
rolegroup.object_name(),
775+
))
774776
.ownerreference_from_resource(hive, None, Some(true))
775777
.context(ObjectMissingMetadataForOwnerRefSnafu)?
776778
.with_recommended_labels(build_recommended_labels(
@@ -1145,9 +1147,8 @@ fn build_metastore_rolegroup_statefulset(
11451147
),
11461148
..LabelSelector::default()
11471149
},
1148-
service_name: Some(format!(
1149-
"{name}-metrics",
1150-
name = rolegroup_ref.object_name()
1150+
service_name: Some(build_headless_listener_service_name(
1151+
rolegroup_ref.object_name(),
11511152
)),
11521153
template: pod_template,
11531154
volume_claim_templates: Some(vec![pvc]),

rust/operator-binary/src/discovery.rs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -164,3 +164,7 @@ fn build_listener_connection_string(
164164
}
165165
Ok(conn_str)
166166
}
167+
168+
pub fn build_headless_listener_service_name(name: String) -> String {
169+
format!("{name}-metrics", name = name)
170+
}

0 commit comments

Comments
 (0)