Skip to content

Commit e950a5a

Browse files
committed
create headless service name in function
1 parent 7262d89 commit e950a5a

1 file changed

Lines changed: 6 additions & 2 deletions

File tree

rust/operator-binary/src/controller.rs

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -783,7 +783,7 @@ fn build_node_rolegroup_service(
783783
) -> Result<Service> {
784784
let metadata = ObjectMetaBuilder::new()
785785
.name_and_namespace(nifi)
786-
.name(format!("{name}-metrics", name = rolegroup.object_name()))
786+
.name(rolegroup_service_name(rolegroup))
787787
.ownerreference_from_resource(nifi, None, Some(true))
788788
.context(ObjectMissingMetadataForOwnerRefSnafu)?
789789
.with_recommended_labels(build_recommended_labels(
@@ -1484,7 +1484,7 @@ async fn build_node_rolegroup_statefulset(
14841484
),
14851485
..LabelSelector::default()
14861486
},
1487-
service_name: Some(rolegroup_ref.object_name()),
1487+
service_name: Some(rolegroup_service_name(rolegroup_ref)),
14881488
template: pod_template,
14891489
update_strategy: Some(StatefulSetUpdateStrategy {
14901490
type_: if rolling_update_supported {
@@ -1523,6 +1523,10 @@ async fn build_node_rolegroup_statefulset(
15231523
})
15241524
}
15251525

1526+
pub fn rolegroup_service_name(rolegroup: &RoleGroupRef<v1alpha1::NifiCluster>) -> String {
1527+
format!("{name}-metrics", name = rolegroup.object_name())
1528+
}
1529+
15261530
async fn get_proxy_hosts(
15271531
client: &Client,
15281532
nifi: &v1alpha1::NifiCluster,

0 commit comments

Comments
 (0)