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

@@ -59,10 +59,11 @@ type ClusterSynchro struct {
 	storageResourceVersions map[schema.GroupVersionResource]map[string]interface{}
 	storageResourceSynchros sync.Map
 
-	syncResources       atomic.Value // []clusterv1alpha2.ClusterGroupResources
-	setSyncResourcesCh  chan struct{}
-	resourceNegotiator  *ResourceNegotiator
-	groupResourceStatus atomic.Value // *GroupResourceStatus
+	syncResources         atomic.Value // []clusterv1alpha2.ClusterGroupResources
+	excludedSyncResources atomic.Value // []clusterv1alpha2.ClusterGroupResources
+	setSyncResourcesCh    chan struct{}
+	resourceNegotiator    *ResourceNegotiator
+	groupResourceStatus   atomic.Value // *GroupResourceStatus
 
 	runningCondition atomic.Value // metav1.Condition
 	healthyCondition atomic.Value // metav1.Condition
@@ -315,6 +316,7 @@ func (s *ClusterSynchro) refreshSyncResources() {
 	if syncResources == nil {
 		return
 	}
+
 	groupResourceStatus, storageResourceSyncConfigs := s.resourceNegotiator.NegotiateSyncResources(syncResources)
 
 	lastGroupResourceStatus := s.groupResourceStatus.Load().(*GroupResourceStatus)

pkg/synchromanager/clustersynchro/cluster_synchro.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 {