mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-23 03:41:45 +00:00
Extender bind should respect IsInterested
This commit is contained in:
parent
7bbc130f5e
commit
848293ba29
@ -508,17 +508,12 @@ func (c *configFactory) CreateFromKeys(predicateKeys, priorityKeys sets.String,
|
||||
|
||||
// getBinderFunc returns a func which returns an extender that supports bind or a default binder based on the given pod.
|
||||
func getBinderFunc(client clientset.Interface, extenders []algorithm.SchedulerExtender) func(pod *v1.Pod) Binder {
|
||||
var extenderBinder algorithm.SchedulerExtender
|
||||
for i := range extenders {
|
||||
if extenders[i].IsBinder() {
|
||||
extenderBinder = extenders[i]
|
||||
break
|
||||
}
|
||||
}
|
||||
defaultBinder := &binder{client}
|
||||
return func(pod *v1.Pod) Binder {
|
||||
if extenderBinder != nil && extenderBinder.IsInterested(pod) {
|
||||
return extenderBinder
|
||||
for _, extender := range extenders {
|
||||
if extender.IsBinder() && extender.IsInterested(pod) {
|
||||
return extender
|
||||
}
|
||||
}
|
||||
return defaultBinder
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user