Skip to content

Commit af5dd1a

Browse files
committed
Generalize managed_resource_meta
1 parent 355a0d8 commit af5dd1a

3 files changed

Lines changed: 9 additions & 12 deletions

File tree

src/cloud-resources/src/crd.rs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -70,15 +70,16 @@ pub struct MaterializeCertSpec {
7070

7171
pub trait ManagedResource: Resource<DynamicType = ()> + Sized {
7272
fn default_labels(&self) -> BTreeMap<String, String> {
73-
recommended_k8s_labels(self.app_name())
73+
BTreeMap::new()
7474
}
7575

7676
fn app_name(&self) -> Option<&str> {
7777
None
7878
}
7979

8080
fn managed_resource_meta(&self, name: String) -> ObjectMeta {
81-
let labels = self.default_labels();
81+
let mut labels = self.default_labels();
82+
labels.extend(recommended_k8s_labels(self.app_name()));
8283
ObjectMeta {
8384
namespace: Some(self.meta().namespace.clone().unwrap()),
8485
name: Some(name),

src/cloud-resources/src/crd/balancer.rs

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ use kube::{CustomResource, Resource, ResourceExt};
1717
use schemars::JsonSchema;
1818
use serde::{Deserialize, Serialize};
1919

20-
use crate::crd::{ManagedResource, MaterializeCertSpec, new_resource_id, recommended_k8s_labels};
20+
use crate::crd::{ManagedResource, MaterializeCertSpec, new_resource_id};
2121

2222
pub mod v1alpha1 {
2323
use super::*;
@@ -161,7 +161,7 @@ pub mod v1alpha1 {
161161

162162
impl ManagedResource for Balancer {
163163
fn default_labels(&self) -> BTreeMap<String, String> {
164-
let mut labels = BTreeMap::from_iter([
164+
BTreeMap::from_iter([
165165
(
166166
"materialize.cloud/organization-name".to_owned(),
167167
self.name_unchecked(),
@@ -175,9 +175,7 @@ pub mod v1alpha1 {
175175
self.resource_id().to_owned(),
176176
),
177177
("materialize.cloud/app".to_owned(), "balancerd".to_owned()),
178-
]);
179-
labels.extend(recommended_k8s_labels(Some("balancerd")));
180-
labels
178+
])
181179
}
182180

183181
fn app_name(&self) -> Option<&str> {

src/cloud-resources/src/crd/console.rs

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ use kube::{CustomResource, Resource, ResourceExt};
1616
use schemars::JsonSchema;
1717
use serde::{Deserialize, Serialize};
1818

19-
use crate::crd::{ManagedResource, MaterializeCertSpec, new_resource_id, recommended_k8s_labels};
19+
use crate::crd::{ManagedResource, MaterializeCertSpec, new_resource_id};
2020
use mz_server_core::listeners::AuthenticatorKind;
2121

2222
pub mod v1alpha1 {
@@ -156,7 +156,7 @@ pub mod v1alpha1 {
156156

157157
impl ManagedResource for Console {
158158
fn default_labels(&self) -> BTreeMap<String, String> {
159-
let mut labels = BTreeMap::from_iter([
159+
BTreeMap::from_iter([
160160
(
161161
"materialize.cloud/organization-name".to_owned(),
162162
self.name_unchecked(),
@@ -170,9 +170,7 @@ pub mod v1alpha1 {
170170
self.resource_id().to_owned(),
171171
),
172172
("materialize.cloud/app".to_owned(), "console".to_owned()),
173-
]);
174-
labels.extend(recommended_k8s_labels(Some("console")));
175-
labels
173+
])
176174
}
177175

178176
fn app_name(&self) -> Option<&str> {

0 commit comments

Comments
 (0)