mirror of https://github.com/k3s-io/k3s
Add back predicate related accessors to scheduler.Configurator
parent
5e9a3adafc
commit
fa39053412
|
@ -88,6 +88,10 @@ type Configurator interface {
|
||||||
// Exposed for testing
|
// Exposed for testing
|
||||||
MakeDefaultErrorFunc(backoff *util.PodBackoff, podQueue core.SchedulingQueue) func(pod *v1.Pod, err error)
|
MakeDefaultErrorFunc(backoff *util.PodBackoff, podQueue core.SchedulingQueue) func(pod *v1.Pod, err error)
|
||||||
|
|
||||||
|
// Predicate related accessors to be exposed for use by k8s.io/autoscaler/cluster-autoscaler
|
||||||
|
GetPredicateMetadataProducer() (algorithm.PredicateMetadataProducer, error)
|
||||||
|
GetPredicates(predicateKeys sets.String) (map[string]algorithm.FitPredicate, error)
|
||||||
|
|
||||||
// Needs to be exposed for things like integration tests where we want to make fake nodes.
|
// Needs to be exposed for things like integration tests where we want to make fake nodes.
|
||||||
GetNodeLister() corelisters.NodeLister
|
GetNodeLister() corelisters.NodeLister
|
||||||
// Exposed for testing
|
// Exposed for testing
|
||||||
|
|
|
@ -17,6 +17,8 @@ limitations under the License.
|
||||||
package scheduler
|
package scheduler
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"fmt"
|
||||||
|
|
||||||
"k8s.io/api/core/v1"
|
"k8s.io/api/core/v1"
|
||||||
"k8s.io/apimachinery/pkg/util/sets"
|
"k8s.io/apimachinery/pkg/util/sets"
|
||||||
clientset "k8s.io/client-go/kubernetes"
|
clientset "k8s.io/client-go/kubernetes"
|
||||||
|
@ -32,6 +34,16 @@ type FakeConfigurator struct {
|
||||||
Config *Config
|
Config *Config
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// GetPredicateMetadataProducer is not implemented yet.
|
||||||
|
func (fc *FakeConfigurator) GetPredicateMetadataProducer() (algorithm.PredicateMetadataProducer, error) {
|
||||||
|
return nil, fmt.Errorf("not implemented")
|
||||||
|
}
|
||||||
|
|
||||||
|
// GetPredicates is not implemented yet.
|
||||||
|
func (fc *FakeConfigurator) GetPredicates(predicateKeys sets.String) (map[string]algorithm.FitPredicate, error) {
|
||||||
|
return nil, fmt.Errorf("not implemented")
|
||||||
|
}
|
||||||
|
|
||||||
// GetHardPodAffinitySymmetricWeight is not implemented yet.
|
// GetHardPodAffinitySymmetricWeight is not implemented yet.
|
||||||
func (fc *FakeConfigurator) GetHardPodAffinitySymmetricWeight() int32 {
|
func (fc *FakeConfigurator) GetHardPodAffinitySymmetricWeight() int32 {
|
||||||
panic("not implemented")
|
panic("not implemented")
|
||||||
|
|
Loading…
Reference in New Issue