feat: support excluded sync resources

Signed-off-by: KubeKyrie <shaolong.qin@daocloud.io>
clusterpedia-io · Dec 28, 2023 · 313a7a4 · 313a7a4
1 parent 810c6c4
commit 313a7a4
Show file tree

Hide file tree

Showing 6 changed files with 34 additions and 0 deletions.
diff --git a/kustomize/crds/cluster.clusterpedia.io_clustersyncresources.yaml b/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:

diff --git a/kustomize/crds/cluster.clusterpedia.io_pediaclusters.yaml b/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:

diff --git a/pkg/generated/openapi/zz_generated.openapi.go b/pkg/generated/openapi/zz_generated.openapi.go
diff --git a/pkg/synchromanager/clustersynchro/resource_negotiator.go b/pkg/synchromanager/clustersynchro/resource_negotiator.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 {

diff --git a/staging/src/github.com/clusterpedia-io/api/cluster/v1alpha2/types.go b/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
+	ExcludedResource []string `json:"excludedResource"`
 }
 
 type ClusterStatus struct {

diff --git a/staging/src/github.com/clusterpedia-io/api/cluster/v1alpha2/zz_generated.deepcopy.go b/staging/src/github.com/clusterpedia-io/api/cluster/v1alpha2/zz_generated.deepcopy.go