Merge pull request #3328 from bibibox/add_pdb_feature_gate_release_1.9

add pdb support feature gate

Makefile

@@ -213,7 +213,7 @@ mod-download-go:
 
 .PHONY: mirror-licenses
 mirror-licenses: mod-download-go; \
-	go install istio.io/tools/cmd/license-lint@latest; \
+	go install istio.io/tools/cmd/license-lint@1.19.7; \
 	cd licenses; \
 	rm -rf `ls ./ | grep -v LICENSE`; \
 	cd -; \

config/license-lint.yaml

@@ -66,3 +66,7 @@ allowlisted_modules:
 - github.com/google/cadvisor
 # Apache-2.0: k8s.io/[email protected]/logo/LICENSE
 - k8s.io/kubernetes
+# BSD: github.com/gogo/[email protected]/LICENSE
+- github.com/gogo/protobuf
+# MIT: sigs.k8s.io/[email protected]/LICENSE
+- sigs.k8s.io/yaml

pkg/features/volcano_features.go

@@ -29,6 +29,9 @@ const (
 	// VolcanoJobSupport can identify and schedule volcano job.
 	VolcanoJobSupport featuregate.Feature = "VolcanoJobSupport"
 
+	// PodDisruptionBudgetsSupport can cache and support PodDisruptionBudgets
+	PodDisruptionBudgetsSupport featuregate.Feature = "PodDisruptionBudgetsSupport"
+
 	// QueueCommandSync supports queue command sync.
 	QueueCommandSync featuregate.Feature = "QueueCommandSync"
 
@@ -47,10 +50,11 @@ func init() {
 }
 
 var defaultVolcanoFeatureGates = map[featuregate.Feature]featuregate.FeatureSpec{
-	WorkLoadSupport:   {Default: true, PreRelease: featuregate.Alpha},
-	VolcanoJobSupport: {Default: true, PreRelease: featuregate.Alpha},
-	QueueCommandSync:  {Default: true, PreRelease: featuregate.Alpha},
-	PriorityClass:     {Default: true, PreRelease: featuregate.Alpha},
+	WorkLoadSupport:             {Default: true, PreRelease: featuregate.Alpha},
+	VolcanoJobSupport:           {Default: true, PreRelease: featuregate.Alpha},
+	PodDisruptionBudgetsSupport: {Default: true, PreRelease: featuregate.Alpha},
+	QueueCommandSync:            {Default: true, PreRelease: featuregate.Alpha},
+	PriorityClass:               {Default: true, PreRelease: featuregate.Alpha},
 	// CSIStorage is explicitly set to false by default.
 	CSIStorage:       {Default: false, PreRelease: featuregate.Alpha},
 	ResourceTopology: {Default: true, PreRelease: featuregate.Alpha},

pkg/scheduler/cache/cache.go

@@ -582,10 +582,9 @@ func (sc *SchedulerCache) addEventHandler() {
 	mySchedulerPodName, c := getMultiSchedulerInfo()
 
 	// explicitly register informers to the factory, otherwise resources listers cannot get anything
-	// even with no error returned. `PodDisruptionBudgets` informer is used by `Pdb` plugin
+	// even with no error returned.
 	// `Namespace` informer is used by `InterPodAffinity` plugin,
 	// `SelectorSpread` and `PodTopologySpread` plugins uses the following four so far.
-	informerFactory.Policy().V1().PodDisruptionBudgets().Informer()
 	informerFactory.Core().V1().Namespaces().Informer()
 	informerFactory.Core().V1().Services().Informer()
 	if utilfeature.DefaultFeatureGate.Enabled(features.WorkLoadSupport) {
@@ -594,6 +593,11 @@ func (sc *SchedulerCache) addEventHandler() {
 		informerFactory.Apps().V1().StatefulSets().Informer()
 	}
 
+	// `PodDisruptionBudgets` informer is used by `Pdb` plugin
+	if utilfeature.DefaultFeatureGate.Enabled(features.PodDisruptionBudgetsSupport) {
+		informerFactory.Policy().V1().PodDisruptionBudgets().Informer()
+	}
+
 	// create informer for node information
 	sc.nodeInformer = informerFactory.Core().V1().Nodes()
 	sc.nodeInformer.Informer().AddEventHandlerWithResyncPeriod(