File tree 2 files changed +16
-0
lines changed
2 files changed +16
-0
lines changed Original file line number Diff line number Diff line change @@ -87,6 +87,14 @@ func (negotiator *ResourceNegotiator) NegotiateSyncResources(syncResources []clu
87
87
for _ , groupResources := range syncResources {
88
88
for _ , resource := range groupResources .Resources {
89
89
syncGR := schema.GroupResource {Group : groupResources .Group , Resource : resource }
90
+
91
+ if clusterpediafeature .FeatureGate .Enabled (features .IgnoreLeaseSync ) {
92
+ // skip leases.coordination.k8s.io
93
+ if syncGR .String () == "leases.coordination.k8s.io" {
94
+ continue
95
+ }
96
+ }
97
+
90
98
apiResource , supportedVersions := negotiator .dynamicDiscovery .GetAPIResourceAndVersions (syncGR )
91
99
if apiResource == nil || len (supportedVersions ) == 0 {
92
100
continue
Original file line number Diff line number Diff line change @@ -61,6 +61,13 @@ const (
61
61
// owner: @iceber
62
62
// alpha: v0.8.0
63
63
StreamHandlePaginatedListForResourceSync featuregate.Feature = "StreamHandlePaginatedListForResourceSync"
64
+
65
+ // IgnoreLeaseSync is a feature gate for the ClusterSynchro to skip syncing leases.coordination.k8s.io,
66
+ // if you enable this feature, these resources will not be synced no matter what `syncResources` are defined.
67
+ //
68
+ // owner: @27149chen
69
+ // alpha: v0.8.0
70
+ IgnoreLeaseSync featuregate.Feature = "IgnoreLeaseSync"
64
71
)
65
72
66
73
func init () {
@@ -78,4 +85,5 @@ var defaultClusterSynchroManagerFeatureGates = map[featuregate.Feature]featurega
78
85
79
86
ForcePaginatedListForResourceSync : {Default : false , PreRelease : featuregate .Alpha },
80
87
StreamHandlePaginatedListForResourceSync : {Default : false , PreRelease : featuregate .Alpha },
88
+ IgnoreLeaseSync : {Default : false , PreRelease : featuregate .Alpha },
81
89
}
You can’t perform that action at this time.
0 commit comments