fix: Make operator namespaced

demeter-run · Nov 7, 2024 · db2a685 · db2a685
1 parent 665ad34
commit db2a685
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/bin/operator.rs b/src/bin/operator.rs
@@ -23,7 +23,7 @@ async fn main() -> Result<()> {
     let context = Arc::new(K8sContext::new(client.clone(), config));
 
     // Create controller for MyApp custom resource
-    let api: Api<HydraDoomNode> = Api::all(client);
+    let api: Api<HydraDoomNode> = Api::default_namespaced(client);
     info!("Running controller.");
     let controller = Controller::new(api, Default::default())
         .run(reconcile, error_policy, context.clone())

diff --git a/src/controller.rs b/src/controller.rs
@@ -379,7 +379,7 @@ impl K8sContext {
     }
 
     async fn patch_statuses(&self) -> anyhow::Result<()> {
-        let api: Api<HydraDoomNode> = Api::all(self.client.clone());
+        let api: Api<HydraDoomNode> = Api::default_namespaced(self.client.clone());
         let crds = api.list(&ListParams::default()).await?;
 
         let mut awaitables = vec![];