@@ -30,7 +30,6 @@ import (
30
30
clientset "k8s.io/client-go/kubernetes"
31
31
"k8s.io/klog/v2"
32
32
"k8s.io/kube-scheduler/config/v1alpha2"
33
- "k8s.io/kubernetes/pkg/controller/volume/scheduling"
34
33
"k8s.io/kubernetes/pkg/scheduler/apis/config"
35
34
"k8s.io/kubernetes/pkg/scheduler/apis/config/scheme"
36
35
"k8s.io/kubernetes/pkg/scheduler/internal/parallelize"
@@ -79,7 +78,6 @@ type framework struct {
79
78
80
79
clientSet clientset.Interface
81
80
informerFactory informers.SharedInformerFactory
82
- volumeBinder scheduling.SchedulerVolumeBinder
83
81
84
82
metricsRecorder * metricsRecorder
85
83
@@ -122,7 +120,6 @@ type frameworkOptions struct {
122
120
informerFactory informers.SharedInformerFactory
123
121
snapshotSharedLister SharedLister
124
122
metricsRecorder * metricsRecorder
125
- volumeBinder scheduling.SchedulerVolumeBinder
126
123
podNominator PodNominator
127
124
runAllFilters bool
128
125
}
@@ -166,13 +163,6 @@ func withMetricsRecorder(recorder *metricsRecorder) Option {
166
163
}
167
164
}
168
165
169
- // WithVolumeBinder sets volume binder for the scheduling framework.
170
- func WithVolumeBinder (binder scheduling.SchedulerVolumeBinder ) Option {
171
- return func (o * frameworkOptions ) {
172
- o .volumeBinder = binder
173
- }
174
- }
175
-
176
166
// WithPodNominator sets podNominator for the scheduling framework.
177
167
func WithPodNominator (nominator PodNominator ) Option {
178
168
return func (o * frameworkOptions ) {
@@ -200,7 +190,6 @@ func NewFramework(r Registry, plugins *config.Plugins, args []config.PluginConfi
200
190
waitingPods : newWaitingPodsMap (),
201
191
clientSet : options .clientSet ,
202
192
informerFactory : options .informerFactory ,
203
- volumeBinder : options .volumeBinder ,
204
193
metricsRecorder : options .metricsRecorder ,
205
194
preemptHandle : options .podNominator ,
206
195
runAllFilters : options .runAllFilters ,
@@ -922,11 +911,6 @@ func (f *framework) SharedInformerFactory() informers.SharedInformerFactory {
922
911
return f .informerFactory
923
912
}
924
913
925
- // VolumeBinder returns the volume binder used by scheduler.
926
- func (f * framework ) VolumeBinder () scheduling.SchedulerVolumeBinder {
927
- return f .volumeBinder
928
- }
929
-
930
914
func (f * framework ) pluginsNeeded (plugins * config.Plugins ) map [string ]config.Plugin {
931
915
pgMap := make (map [string ]config.Plugin )
932
916
0 commit comments