chore: we should use default ns for gw agents in k8s

config/src/converters/k8s/config/gateway_config.rs

@@ -56,7 +56,7 @@ fn validate_metadata(ga: &GatewayAgent) -> Result<K8sInput, FromK8sConversionErr
             "Missing namespace".to_string(),
         ))?;
 
-    if namespace.as_str() != "fab" {
+    if namespace.as_str() != "default" {
         return Err(FromK8sConversionError::K8sInfra(format!(
             "Invalid namespace {namespace}"
         )));

k8s-intf/src/bolero/crd.rs

@@ -33,7 +33,7 @@ impl TypeGenerator for LegalValue<GatewayAgent> {
             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::<LegalValue<GatewayAgentSpec>>()?.take(),

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<GatewayAgent> = Api::namespaced(client.clone(), "fab");
+    // Relevant gateway agent objects are in the "default" namespace
+    let gws: Api<GatewayAgent> = 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<GatewayAgent> = Api::namespaced(client.clone(), "fab");
+    let api: Api<GatewayAgent> = Api::namespaced(client.clone(), "default");
 
     for attempt_num in 0..NUM_CONFLICT_RETRIES {
         let mut status_obj = api.get_status(gateway_object_name).await?;

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;
                         }