diff --git a/crates/fluvio-controlplane-metadata/src/remote_cluster/mod.rs b/crates/fluvio-controlplane-metadata/src/remote_cluster/mod.rs index bf38ff872c..9b72f83701 100644 --- a/crates/fluvio-controlplane-metadata/src/remote_cluster/mod.rs +++ b/crates/fluvio-controlplane-metadata/src/remote_cluster/mod.rs @@ -9,7 +9,10 @@ mod k8; mod metadata { - use crate::core::{Spec, Status}; + use crate::{ + core::{Spec, Status}, + extended::{ObjectType, SpecExt}, + }; use super::*; @@ -20,6 +23,10 @@ mod metadata { type Owner = Self; } + impl SpecExt for RemoteClusterSpec { + const OBJECT_TYPE: ObjectType = ObjectType::RemoteCluster; + } + impl Status for RemoteClusterStatus {} #[cfg(feature = "k8")] diff --git a/crates/fluvio-controlplane-metadata/src/upstream_cluster/mod.rs b/crates/fluvio-controlplane-metadata/src/upstream_cluster/mod.rs index afbb53ce95..67e6387df9 100644 --- a/crates/fluvio-controlplane-metadata/src/upstream_cluster/mod.rs +++ b/crates/fluvio-controlplane-metadata/src/upstream_cluster/mod.rs @@ -9,7 +9,10 @@ mod k8; mod metadata { - use crate::core::{Spec, Status}; + use crate::{ + core::{Spec, Status}, + extended::{ObjectType, SpecExt}, + }; use super::*; @@ -20,6 +23,10 @@ mod metadata { type Owner = Self; } + impl SpecExt for UpstreamClusterSpec { + const OBJECT_TYPE: ObjectType = ObjectType::UpstreamCluster; + } + impl Status for UpstreamClusterStatus {} #[cfg(feature = "k8")]