Add Gateway API delete func

weibaohui · Jul 12, 2024 · 80b2c6b · 80b2c6b
1 parent b185889
commit 80b2c6b
Show file tree

Hide file tree

Showing 11 changed files with 105 additions and 34 deletions.
diff --git a/BlazorApp/Service/k8s/impl/BackendLBPolicyService.cs b/BlazorApp/Service/k8s/impl/BackendLBPolicyService.cs
@@ -1,5 +1,6 @@
 using System.Threading.Tasks;
 using Entity.Crd.Gateway;
+using k8s;
 
 namespace BlazorApp.Service.k8s.impl;
 
@@ -8,7 +9,7 @@ public class BackendLBPolicyService(IKubeService kubeService)
 {
     public new async Task<object> Delete(string ns, string name)
     {
-        return Task.CompletedTask;
-        // return await kubeService.Client().DeleteNamespacedBackendLBPolicyAsync(name, ns);
+        return await kubeService.Client().CustomObjects
+            .DeleteNamespacedCustomObjectAsync("gateway.networking.k8s.io", "v1alpha2", ns, "backendlbpolicies", name);
     }
-}
+}
diff --git a/BlazorApp/Service/k8s/impl/BackendTLSPolicyService.cs b/BlazorApp/Service/k8s/impl/BackendTLSPolicyService.cs
@@ -1,5 +1,6 @@
 using System.Threading.Tasks;
 using Entity.Crd.Gateway;
+using k8s;
 
 namespace BlazorApp.Service.k8s.impl;
 
@@ -8,8 +9,7 @@ public class BackendTLSPolicyService(IKubeService kubeService)
 {
     public new async Task<object> Delete(string ns, string name)
     {
-        return Task.CompletedTask;
-
-        // return await kubeService.Client().DeleteNamespacedBackendTLSPolicyAsync(name, ns);
+        return await kubeService.Client().CustomObjects
+            .DeleteNamespacedCustomObjectAsync("gateway.networking.k8s.io", "v1alpha3", ns, "backendtlspolicies", name);
     }
-}
+}
diff --git a/BlazorApp/Service/k8s/impl/GatewayClassService.cs b/BlazorApp/Service/k8s/impl/GatewayClassService.cs
@@ -1,14 +1,14 @@
 using System.Threading.Tasks;
 using Entity.Crd.Gateway;
+using k8s;
 
 namespace BlazorApp.Service.k8s.impl;
 
 public class GatewayClassService(IKubeService kubeService) : CommonAction<V1GatewayClass>, IGatewayClassService
 {
     public new async Task<object> Delete(string ns, string name)
     {
-        return Task.CompletedTask;
-
-        // return await kubeService.Client().DeleteNamespacedGatewayClassAsync(name, ns);
+        return await kubeService.Client().CustomObjects
+            .DeleteClusterCustomObjectAsync("gateway.networking.k8s.io", "v1", "gatewayclasses", name);
     }
-}
+}
diff --git a/BlazorApp/Service/k8s/impl/GatewayService.cs b/BlazorApp/Service/k8s/impl/GatewayService.cs
@@ -2,6 +2,7 @@
 using System.Linq;
 using System.Threading.Tasks;
 using Entity.Crd.Gateway;
+using k8s;
 using k8s.Models;
 
 namespace BlazorApp.Service.k8s.impl;
@@ -10,9 +11,8 @@ public class GatewayService(IKubeService kubeService) : CommonAction<V1Gateway>,
 {
     public new async Task<object> Delete(string ns, string name)
     {
-        return Task.CompletedTask;
-
-        // return await kubeService.Client().DeleteNamespacedGatewayAsync(name, ns);
+        return await kubeService.Client().CustomObjects
+            .DeleteNamespacedCustomObjectAsync("gateway.networking.k8s.io", "v1", ns, "gateways", name);
     }
 
     public IList<V1Gateway> ListByParentRefs(IList<ParentReference> parentRefs)

diff --git a/BlazorApp/Service/k8s/impl/GrpcRouteService.cs b/BlazorApp/Service/k8s/impl/GrpcRouteService.cs
@@ -2,6 +2,7 @@
 using System.Linq;
 using System.Threading.Tasks;
 using Entity.Crd.Gateway;
+using k8s;
 using k8s.Models;
 
 namespace BlazorApp.Service.k8s.impl;
@@ -10,9 +11,8 @@ public class GrpcRouteService(IKubeService kubeService) : CommonAction<V1GRPCRou
 {
     public new async Task<object> Delete(string ns, string name)
     {
-        return Task.CompletedTask;
-
-        // return await kubeService.Client().DeleteNamespacedGrpcRouteAsync(name, ns);
+        return await kubeService.Client().CustomObjects
+            .DeleteNamespacedCustomObjectAsync("gateway.networking.k8s.io", "v1", ns, "grpcroutes", name);
     }
 
     public IList<V1GRPCRoute> ListByServiceList(List<V1Service> services)

diff --git a/BlazorApp/Service/k8s/impl/HttpRouteService.cs b/BlazorApp/Service/k8s/impl/HttpRouteService.cs
@@ -2,6 +2,7 @@
 using System.Linq;
 using System.Threading.Tasks;
 using Entity.Crd.Gateway;
+using k8s;
 using k8s.Models;
 
 namespace BlazorApp.Service.k8s.impl;
@@ -10,9 +11,8 @@ public class HttpRouteService(IKubeService kubeService) : CommonAction<V1HTTPRou
 {
     public new async Task<object> Delete(string ns, string name)
     {
-        return Task.CompletedTask;
-
-        // return await kubeService.Client().DeleteNamespacedHttpRouteAsync(name, ns);
+        return await kubeService.Client().CustomObjects
+            .DeleteNamespacedCustomObjectAsync("gateway.networking.k8s.io", "v1", ns, "httproutes", name);
     }
 
     public IList<V1HTTPRoute> ListByServiceList(List<V1Service> services)

diff --git a/BlazorApp/Service/k8s/impl/ReferenceGrantService.cs b/BlazorApp/Service/k8s/impl/ReferenceGrantService.cs
@@ -1,5 +1,6 @@
 using System.Threading.Tasks;
 using Entity.Crd.Gateway;
+using k8s;
 
 namespace BlazorApp.Service.k8s.impl;
 
@@ -8,8 +9,7 @@ public class ReferenceGrantService(IKubeService kubeService)
 {
     public new async Task<object> Delete(string ns, string name)
     {
-        return Task.CompletedTask;
-
-        // return await kubeService.Client().DeleteNamespacedReferenceGrantAsync(name, ns);
+        return await kubeService.Client().CustomObjects
+            .DeleteNamespacedCustomObjectAsync("gateway.networking.k8s.io", "v1alpha2", ns, "referencegrants", name);
     }
-}
+}
diff --git a/BlazorApp/Service/k8s/impl/ResourceCrudService.cs b/BlazorApp/Service/k8s/impl/ResourceCrudService.cs
@@ -48,10 +48,80 @@ public Task<object> DeleteItem(string kind, string ns, string name)
             "ClusterRoleBinding" => OnClusterRoleBindingDelete(ns, name),
             "RoleBinding" => OnRoleBindingDelete(ns, name),
             "CustomResourceDefinition" => OnCustomResourceDefinitionDelete(ns, name),
+            "GatewayClass" => OnGatewayClassDelete(ns, name),
+            "Gateway" => OnGatewayDelete(ns, name),
+            "HTTPRoute" => OnHttpRouteDelete(ns, name),
+            "TLSRoute" => OnTlsRouteDelete(ns, name),
+            "GRPCRoute" => OnGrpcRouteDelete(ns, name),
+            "UDPRoute" => OnUdpRouteDelete(ns, name),
+            "TCPRoute" => OnTcpRouteDelete(ns, name),
+            "ReferenceGrant" => OnReferenceGrantDelete(ns, name),
+            "BackendTLSPolicy" => OnBackendTlsPolicyDelete(ns, name),
+            "BackendLBPolicy" => OnBackendLbPolicyDelete(ns, name),
             _ => OnXDelete(kind, ns, name)
         });
     }
 
+    private async Task<object> OnBackendLbPolicyDelete(string ns, string name)
+    {
+        return await kubeService.Client().CustomObjects
+            .DeleteNamespacedCustomObjectAsync("gateway.networking.k8s.io", "v1alpha2", ns, "backendlbpolicies", name);
+    }
+
+    private async Task<object> OnBackendTlsPolicyDelete(string ns, string name)
+    {
+        return await kubeService.Client().CustomObjects
+            .DeleteNamespacedCustomObjectAsync("gateway.networking.k8s.io", "v1alpha3", ns, "backendtlspolicies", name);
+    }
+
+    private async Task<object> OnReferenceGrantDelete(string ns, string name)
+    {
+        return await kubeService.Client().CustomObjects
+            .DeleteNamespacedCustomObjectAsync("gateway.networking.k8s.io", "v1alpha2", ns, "referencegrants", name);
+    }
+
+    private async Task<object> OnTcpRouteDelete(string ns, string name)
+    {
+        return await kubeService.Client().CustomObjects
+            .DeleteNamespacedCustomObjectAsync("gateway.networking.k8s.io", "v1alpha2", ns, "tcproutes", name);
+    }
+
+    private async Task<object> OnUdpRouteDelete(string ns, string name)
+    {
+        return await kubeService.Client().CustomObjects
+            .DeleteNamespacedCustomObjectAsync("gateway.networking.k8s.io", "v1alpha2", ns, "udproutes", name);
+    }
+
+    private async Task<object> OnGrpcRouteDelete(string ns, string name)
+    {
+        return await kubeService.Client().CustomObjects
+            .DeleteNamespacedCustomObjectAsync("gateway.networking.k8s.io", "v1", ns, "grpcroutes", name);
+    }
+
+    private async Task<object> OnTlsRouteDelete(string ns, string name)
+    {
+        return await kubeService.Client().CustomObjects
+            .DeleteNamespacedCustomObjectAsync("gateway.networking.k8s.io", "v1alpha2", ns, "tlsroutes", name);
+    }
+
+    private async Task<object> OnHttpRouteDelete(string ns, string name)
+    {
+        return await kubeService.Client().CustomObjects
+            .DeleteNamespacedCustomObjectAsync("gateway.networking.k8s.io", "v1", ns, "httproutes", name);
+    }
+
+    private async Task<object> OnGatewayDelete(string ns, string name)
+    {
+        return await kubeService.Client().CustomObjects
+            .DeleteNamespacedCustomObjectAsync("gateway.networking.k8s.io", "v1", ns, "gateways", name);
+    }
+
+    private async Task<object> OnGatewayClassDelete(string ns, string name)
+    {
+        return await kubeService.Client().CustomObjects
+            .DeleteClusterCustomObjectAsync("gateway.networking.k8s.io", "v1", "gatewayclasses", name);
+    }
+
     private async Task<V1PersistentVolumeClaim> OnPersistentVolumeClaimDelete(string ns, string name)
     {
         return await kubeService.Client().DeleteNamespacedPersistentVolumeClaimAsync(name, ns);

diff --git a/BlazorApp/Service/k8s/impl/TcpRouteService.cs b/BlazorApp/Service/k8s/impl/TcpRouteService.cs
@@ -2,6 +2,7 @@
 using System.Linq;
 using System.Threading.Tasks;
 using Entity.Crd.Gateway;
+using k8s;
 using k8s.Models;
 
 namespace BlazorApp.Service.k8s.impl;
@@ -10,9 +11,8 @@ public class TcpRouteService(IKubeService kubeService) : CommonAction<V1Alpha2TC
 {
     public new async Task<object> Delete(string ns, string name)
     {
-        return Task.CompletedTask;
-
-        // return await kubeService.Client().DeleteNamespacedTcpRouteAsync(name, ns);
+        return await kubeService.Client().CustomObjects
+            .DeleteNamespacedCustomObjectAsync("gateway.networking.k8s.io", "v1alpha2", ns, "tcproutes", name);
     }
 
     public IList<V1Alpha2TCPRoute> ListByServiceList(List<V1Service> services)

diff --git a/BlazorApp/Service/k8s/impl/TlsRouteService.cs b/BlazorApp/Service/k8s/impl/TlsRouteService.cs
@@ -1,14 +1,14 @@
 using System.Threading.Tasks;
 using Entity.Crd.Gateway;
+using k8s;
 
 namespace BlazorApp.Service.k8s.impl;
 
 public class TlsRouteService(IKubeService kubeService) : CommonAction<V1Alpha2TLSRoute>, ITlsRouteService
 {
     public new async Task<object> Delete(string ns, string name)
     {
-        return Task.CompletedTask;
-
-        // return await kubeService.Client().DeleteNamespacedTlsRouteAsync(name, ns);
+        return await kubeService.Client().CustomObjects
+            .DeleteNamespacedCustomObjectAsync("gateway.networking.k8s.io", "v1alpha2", ns, "tlsroutes", name);
     }
-}
+}
diff --git a/BlazorApp/Service/k8s/impl/UdpRouteService.cs b/BlazorApp/Service/k8s/impl/UdpRouteService.cs
@@ -2,6 +2,7 @@
 using System.Linq;
 using System.Threading.Tasks;
 using Entity.Crd.Gateway;
+using k8s;
 using k8s.Models;
 
 namespace BlazorApp.Service.k8s.impl;
@@ -10,9 +11,8 @@ public class UdpRouteService(IKubeService kubeService) : CommonAction<V1Alpha2UD
 {
     public new async Task<object> Delete(string ns, string name)
     {
-        return Task.CompletedTask;
-
-        // return await kubeService.Client().DeleteNamespacedUdpRouteAsync(name, ns);
+        return await kubeService.Client().CustomObjects
+            .DeleteNamespacedCustomObjectAsync("gateway.networking.k8s.io", "v1alpha2", ns, "udproutes", name);
     }
 
     public IList<V1Alpha2UDPRoute> ListByServiceList(List<V1Service> services)