Skip to content

Commit 9d007de

Browse files
committed
Improve consistency
1 parent af5dd1a commit 9d007de

4 files changed

Lines changed: 14 additions & 11 deletions

File tree

src/orchestratord/src/controller/balancer.rs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -193,7 +193,6 @@ impl Context {
193193
None
194194
};
195195
let mut pod_template_labels = balancer.default_labels();
196-
pod_template_labels.extend(recommended_k8s_labels(balancer.app_name()));
197196
pod_template_labels.insert(
198197
"materialize.cloud/name".to_owned(),
199198
balancer.deployment_name(),
@@ -355,10 +354,13 @@ impl Context {
355354
..Default::default()
356355
};
357356

357+
let match_labels = pod_template_labels.clone();
358+
pod_template_labels.extend(recommended_k8s_labels(balancer.app_name()));
359+
358360
let deployment_spec = DeploymentSpec {
359361
replicas: Some(balancer.replicas()),
360362
selector: LabelSelector {
361-
match_labels: Some(pod_template_labels.clone()),
363+
match_labels: Some(match_labels),
362364
..Default::default()
363365
},
364366
strategy: Some(DeploymentStrategy {

src/orchestratord/src/controller/console.rs

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ use tracing::{trace, warn};
3939

4040
use crate::{
4141
Error,
42-
k8s::{apply_resource, get_resource, replace_resource},
42+
k8s::{apply_resource, get_resource, recommended_k8s_labels, replace_resource},
4343
tls::{DefaultCertificateSpecs, create_certificate, issuer_ref_defined},
4444
};
4545
use mz_cloud_resources::crd::{
@@ -402,10 +402,13 @@ ssl_certificate_key /nginx/tls/tls.key;",
402402
..Default::default()
403403
};
404404

405+
let match_labels = pod_template_labels.clone();
406+
pod_template_labels.extend(recommended_k8s_labels("console".into()));
407+
405408
let deployment_spec = DeploymentSpec {
406409
replicas: Some(console.replicas()),
407410
selector: LabelSelector {
408-
match_labels: Some(pod_template_labels.clone()),
411+
match_labels: Some(match_labels),
409412
..Default::default()
410413
},
411414
template: PodTemplateSpec {

src/orchestratord/src/controller/materialize/generation.rs

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -43,8 +43,8 @@ use super::matching_image_from_environmentd_image_ref;
4343
use crate::k8s::{apply_resource, delete_resource, get_resource};
4444
use crate::tls::issuer_ref_defined;
4545
use mz_cloud_provider::CloudProvider;
46-
use mz_cloud_resources::crd::ManagedResource;
4746
use mz_cloud_resources::crd::materialize::v1alpha1::Materialize;
47+
use mz_cloud_resources::crd::{ManagedResource, recommended_k8s_labels};
4848
use mz_ore::instrument;
4949

5050
static V140_DEV0: LazyLock<Version> = LazyLock::new(|| Version {
@@ -1131,11 +1131,7 @@ fn create_environmentd_statefulset_object(
11311131
"materialize.cloud/app".to_owned(),
11321132
mz.environmentd_app_name(),
11331133
);
1134-
pod_template_labels.insert("app".to_owned(), "environmentd".to_string());
1135-
pod_template_labels.insert(
1136-
"app.kubernetes.io/name".to_owned(),
1137-
"environmentd".to_string(),
1138-
);
1134+
pod_template_labels.extend(recommended_k8s_labels("environmentd".into()));
11391135
pod_template_labels.extend(
11401136
mz.spec
11411137
.pod_labels

src/orchestratord/src/k8s.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -200,6 +200,8 @@ pub fn recommended_k8s_labels(app_name: String) -> BTreeMap<String, String> {
200200
"materialize-operator".into(),
201201
);
202202
labels.insert("app.kubernetes.io/part-of".into(), "materialize".into());
203-
labels.insert("app.kubernetes.io/name".into(), app_name);
203+
labels.insert("app.kubernetes.io/name".into(), app_name.to_owned());
204+
// legacy label
205+
labels.insert("app".into(), app_name.to_owned());
204206
labels
205207
}

0 commit comments

Comments
 (0)