feat: support excluded sync resources

kustomize/crds/cluster.clusterpedia.io_clustersyncresources.yaml

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

kustomize/crds/cluster.clusterpedia.io_pediaclusters.yaml

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

pkg/synchromanager/clustersynchro/resource_negotiator.go

@@ -42,6 +42,7 @@ func (negotiator *ResourceNegotiator) SetSyncAllCustomResources(sync bool) {
 func (negotiator *ResourceNegotiator) NegotiateSyncResources(syncResources []clusterv1alpha2.ClusterGroupResources) (*GroupResourceStatus, map[schema.GroupVersionResource]syncConfig) {
 	var syncAllResources bool
 	var watchKubeVersion, watchAggregatorResourceTypes bool
+	originSyncResources := syncResources
 	for i, syncResource := range syncResources {
 		if syncResource.Group == "*" {
 			syncAllResources = true
@@ -62,6 +63,7 @@ func (negotiator *ResourceNegotiator) NegotiateSyncResources(syncResources []clu
 					klog.InfoS("Skip resource sync", "cluster", negotiator.name, "group", syncResource.Group, "reason", "not match group")
 				} else {
 					syncResourcesByGroup.Versions = syncResource.Versions
+					syncResourcesByGroup.ExcludeResources = syncResource.ExcludeResources
 					syncResources[i] = *syncResourcesByGroup
 					if groupType == discovery.KubeResource {
 						watchKubeVersion = true
@@ -74,6 +76,18 @@ func (negotiator *ResourceNegotiator) NegotiateSyncResources(syncResources []clu
 
 	if syncAllResources {
 		syncResources = negotiator.dynamicDiscovery.GetAllResourcesAsSyncResources()
+		allExcludeResources := make([]string, 0)
+		for _, gr := range originSyncResources {
+			if len(gr.ExcludeResources) > 0 {
+				allExcludeResources = append(allExcludeResources, gr.ExcludeResources...)
+			}
+		}
+		allExcludeResourcesSet := sets.New(allExcludeResources...)
+		for k, groupResources := range syncResources {
+			if allExcludeResourcesSet.Has(groupResources.Resources[0]) {
+				syncResources[k].ExcludeResources = groupResources.Resources
+			}
+		}
 	} else if negotiator.syncAllCustomResources && clusterpediafeature.FeatureGate.Enabled(features.AllowSyncAllCustomResources) {
 		syncResources = negotiator.dynamicDiscovery.AttachAllCustomResourcesToSyncResources(syncResources)
 	}
@@ -85,7 +99,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.ExcludeResources...)
 		for _, resource := range groupResources.Resources {
+			if excludedResourcesSet.Has(resource) {
+				continue
+			}
 			syncGR := schema.GroupResource{Group: groupResources.Group, Resource: resource}
 
 			if clusterpediafeature.FeatureGate.Enabled(features.IgnoreSyncLease) {

staging/src/github.com/clusterpedia-io/api/cluster/v1alpha2/types.go

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