feat: support excluded sync resources

Signed-off-by: KubeKyrie <[email protected]>

Author: KubeKyrie

kustomize/crds/cluster.clusterpedia.io_clustersyncresources.yaml

@@ -35,6 +35,10 @@ spec:
               syncResources:
                 items:
                   properties:
+                    excludedResource:
+                      items:
+                        type: string
+                      type: array
                     group:
                       type: string
                     resources:

kustomize/crds/cluster.clusterpedia.io_pediaclusters.yaml

@@ -79,6 +79,10 @@ spec:
               syncResources:
                 items:
                   properties:
+                    excludedResource:
+                      items:
+                        type: string
+                      type: array
                     group:
                       type: string
                     resources:

pkg/generated/openapi/zz_generated.openapi.go

@@ -85,7 +85,11 @@ func (negotiator *ResourceNegotiator) NegotiateSyncResources(syncResources []clu
 	var groupResourceStatus = NewGroupResourceStatus()
 	var storageResourceSyncConfigs = make(map[schema.GroupVersionResource]syncConfig)
 	for _, groupResources := range syncResources {
+		excludedResourcesSet := sets.New(groupResources.ExcludedResource...)
 		for _, resource := range groupResources.Resources {
+			if excludedResourcesSet.Has(resource) {
+				continue
+			}
 			syncGR := schema.GroupResource{Group: groupResources.Group, Resource: resource}
 			apiResource, supportedVersions := negotiator.dynamicDiscovery.GetAPIResourceAndVersions(syncGR)
 			if apiResource == nil || len(supportedVersions) == 0 {

pkg/synchromanager/clustersynchro/resource_negotiator.go

@@ -109,6 +109,9 @@ type ClusterGroupResources struct {
 	// +kubebuilder:validation:Required
 	// +kubebuilder:validation:MinItems=1
 	Resources []string `json:"resources"`
+
+	// +optional
+	ExcludedResource []string `json:"excludedResource"`
 }
 
 type ClusterStatus struct {