diff --git a/config/src/converters/k8s/config/gateway_config.rs b/config/src/converters/k8s/config/gateway_config.rs index 274461aa0..422969b55 100644 --- a/config/src/converters/k8s/config/gateway_config.rs +++ b/config/src/converters/k8s/config/gateway_config.rs @@ -56,7 +56,7 @@ fn validate_metadata(ga: &GatewayAgent) -> Result { metadata: ObjectMeta { name: Some(simple_hostname(d)?), generation: Some(d.gen_i64(Bound::Excluded(&0), Bound::Unbounded)?), - namespace: Some("fab".to_string()), + namespace: Some("default".to_string()), ..Default::default() }, spec: d.produce::>()?.take(), diff --git a/k8s-intf/src/client.rs b/k8s-intf/src/client.rs index a58b42c96..69c6eb285 100644 --- a/k8s-intf/src/client.rs +++ b/k8s-intf/src/client.rs @@ -40,8 +40,8 @@ pub async fn watch_gateway_agent_crd( callback: impl AsyncFn(&GatewayAgent), ) -> Result<(), WatchError> { let client = Client::try_default().await?; - // Relevant gateway agent objects are in the "fab" namespace - let gws: Api = Api::namespaced(client.clone(), "fab"); + // Relevant gateway agent objects are in the "default" namespace + let gws: Api = Api::namespaced(client.clone(), "default"); info!( "Starting K8s GatewayAgent watcher. GW_API_VERSION = {}", @@ -89,7 +89,7 @@ pub async fn replace_gateway_status( status: &GatewayAgentStatus, ) -> Result<(), ReplaceStatusError> { let client = Client::try_default().await?; - let api: Api = Api::namespaced(client.clone(), "fab"); + let api: Api = Api::namespaced(client.clone(), "default"); for attempt_num in 0..NUM_CONFLICT_RETRIES { let mut status_obj = api.get_status(gateway_object_name).await?; diff --git a/k8s-less/src/local.rs b/k8s-less/src/local.rs index a8be0069d..cef42de91 100644 --- a/k8s-less/src/local.rs +++ b/k8s-less/src/local.rs @@ -102,7 +102,7 @@ pub async fn kubeless_watch_gateway_agent_crd( Ok(crd_spec) => { let mut crd = GatewayAgent::new(gwname, crd_spec); crd.metadata.generation = Some(generation); - crd.metadata.namespace = Some("fab".to_string()); + crd.metadata.namespace = Some("default".to_string()); generation += 1; callback(&crd).await; }