Skip to content

Commit 37743a9

Browse files
adwk67NickLarsenNZ
andauthored
Update rust/operator-binary/src/superset_controller.rs
Co-authored-by: Nick <[email protected]>
1 parent a967ae7 commit 37743a9

File tree

1 file changed

+28
-22
lines changed

1 file changed

+28
-22
lines changed

rust/operator-binary/src/superset_controller.rs

Lines changed: 28 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -678,28 +678,34 @@ pub fn build_group_listener(
678678
rolegroup: &RoleGroupRef<v1alpha1::SupersetCluster>,
679679
listener_class: String,
680680
) -> Result<Listener> {
681-
Ok(Listener {
682-
metadata: ObjectMetaBuilder::new()
683-
.name_and_namespace(superset)
684-
.name(superset.group_listener_name(rolegroup))
685-
.ownerreference_from_resource(superset, None, Some(true))
686-
.context(ObjectMissingMetadataForOwnerRefSnafu)?
687-
.with_recommended_labels(build_recommended_labels(
688-
superset,
689-
SUPERSET_CONTROLLER_NAME,
690-
&resolved_product_image.app_version_label,
691-
&rolegroup.role,
692-
&rolegroup.role_group,
693-
))
694-
.context(MetadataBuildSnafu)?
695-
.build(),
696-
spec: ListenerSpec {
697-
class_name: Some(listener_class),
698-
ports: Some(listener_ports()),
699-
..ListenerSpec::default()
700-
},
701-
status: None,
702-
})
681+
let metadata = ObjectMetaBuilder::new()
682+
.name_and_namespace(superset)
683+
.name(superset.group_listener_name(rolegroup))
684+
.ownerreference_from_resource(superset, None, Some(true))
685+
.context(ObjectMissingMetadataForOwnerRefSnafu)?
686+
.with_recommended_labels(build_recommended_labels(
687+
superset,
688+
SUPERSET_CONTROLLER_NAME,
689+
&resolved_product_image.app_version_label,
690+
&rolegroup.role,
691+
&rolegroup.role_group,
692+
))
693+
.context(MetadataBuildSnafu)?
694+
.build();
695+
696+
let spec = ListenerSpec {
697+
class_name: Some(listener_class),
698+
ports: Some(listener_ports()),
699+
..Default::default()
700+
};
701+
702+
let listener = Listener {
703+
metadata,
704+
spec,
705+
..Default::default()
706+
}
707+
708+
Ok(listener)
703709
}
704710

705711
fn listener_ports() -> Vec<ListenerPort> {

0 commit comments

Comments
 (0)