delete alertrule

pkg/apiserver/apiserver.go

@@ -88,6 +88,7 @@ func (s *APIServer) installK8sClient() {
 				global.PCM_LOG.Error("init dynamicClient error.", zap.Error(err))
 			}
 			s.DynamicClientMap[cluster.Name] = dynamicClient
+
 			clientSet, err := kubernetes.NewForConfig(restConfig)
 			if err != nil {
 				global.PCM_LOG.Error("init clientSet error.", zap.Error(err))

routers/api/v1/crd.go

@@ -0,0 +1,43 @@
+package v1
+
+import (
+	"github.com/gin-gonic/gin"
+	"jcc-schedule/pkg/apiserver"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/runtime/schema"
+	"net/http"
+)
+
+type Grv struct {
+	Group    string `json:"group"`
+	Version  string `json:"version"`
+	Resource string `json:"resource"`
+}
+
+type CrdStruct struct {
+	ClusterName string `json:"clusterName"`
+	Grv         Grv    `json:"grv"`
+	Name        string `json:"name"`
+}
+
+func CrdDelete(ctx *gin.Context) {
+	var p CrdStruct
+	if err := ctx.BindJSON(&p); err != nil {
+		Response(ctx, http.StatusBadRequest, "invalid request params.", "")
+		return
+	}
+
+	if _, ok := apiserver.ApiServer.DynamicClientMap[p.ClusterName]; !ok {
+		Response(ctx, http.StatusBadRequest, "dynamic client nil.", "")
+		return
+	}
+	grv := schema.GroupVersionResource{
+		Group:    p.Grv.Group,
+		Version:  p.Grv.Version,
+		Resource: p.Grv.Resource,
+	}
+	if err := apiserver.ApiServer.DynamicClientMap[p.ClusterName].Resource(grv).Namespace("monitoring-system").Delete(ctx, p.Name, metav1.DeleteOptions{}); err != nil {
+		Response(ctx, http.StatusInternalServerError, "delete crd err.", "")
+		return
+	}
+}

routers/router.go

@@ -59,6 +59,10 @@ func InitRouter() *gin.Engine {
 		//operate
 		operate := apiv1.Group("operate")
 		operate.POST("/apply", v1.Apply)
+
+		// crd
+		crd := apiv1.Group("crd")
+		crd.DELETE("", v1.CrdDelete)
 	}
 
 	return r