mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-23 03:41:45 +00:00
* allow preScore to return skip status to skip running the corresponding score extension * add test case for all skipped * add test case for select host * update plugin status * skip score when all plugins are skipped * update
283 lines
8.9 KiB
Go
283 lines
8.9 KiB
Go
/*
|
|
Copyright 2020 The Kubernetes Authors.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
package testing
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"sync/atomic"
|
|
"time"
|
|
|
|
v1 "k8s.io/api/core/v1"
|
|
"k8s.io/apimachinery/pkg/runtime"
|
|
"k8s.io/kubernetes/pkg/scheduler/framework"
|
|
frameworkruntime "k8s.io/kubernetes/pkg/scheduler/framework/runtime"
|
|
)
|
|
|
|
// ErrReasonFake is a fake error message denotes the filter function errored.
|
|
const ErrReasonFake = "Nodes failed the fake plugin"
|
|
|
|
// FalseFilterPlugin is a filter plugin which always return Unschedulable when Filter function is called.
|
|
type FalseFilterPlugin struct{}
|
|
|
|
// Name returns name of the plugin.
|
|
func (pl *FalseFilterPlugin) Name() string {
|
|
return "FalseFilter"
|
|
}
|
|
|
|
// Filter invoked at the filter extension point.
|
|
func (pl *FalseFilterPlugin) Filter(_ context.Context, _ *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status {
|
|
return framework.NewStatus(framework.Unschedulable, ErrReasonFake)
|
|
}
|
|
|
|
// NewFalseFilterPlugin initializes a FalseFilterPlugin and returns it.
|
|
func NewFalseFilterPlugin(_ runtime.Object, _ framework.Handle) (framework.Plugin, error) {
|
|
return &FalseFilterPlugin{}, nil
|
|
}
|
|
|
|
// TrueFilterPlugin is a filter plugin which always return Success when Filter function is called.
|
|
type TrueFilterPlugin struct{}
|
|
|
|
// Name returns name of the plugin.
|
|
func (pl *TrueFilterPlugin) Name() string {
|
|
return "TrueFilter"
|
|
}
|
|
|
|
// Filter invoked at the filter extension point.
|
|
func (pl *TrueFilterPlugin) Filter(_ context.Context, _ *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status {
|
|
return nil
|
|
}
|
|
|
|
// NewTrueFilterPlugin initializes a TrueFilterPlugin and returns it.
|
|
func NewTrueFilterPlugin(_ runtime.Object, _ framework.Handle) (framework.Plugin, error) {
|
|
return &TrueFilterPlugin{}, nil
|
|
}
|
|
|
|
type FakePreFilterAndFilterPlugin struct {
|
|
*FakePreFilterPlugin
|
|
*FakeFilterPlugin
|
|
}
|
|
|
|
// Name returns name of the plugin.
|
|
func (pl FakePreFilterAndFilterPlugin) Name() string {
|
|
return "FakePreFilterAndFilterPlugin"
|
|
}
|
|
|
|
// FakeFilterPlugin is a test filter plugin to record how many times its Filter() function have
|
|
// been called, and it returns different 'Code' depending on its internal 'failedNodeReturnCodeMap'.
|
|
type FakeFilterPlugin struct {
|
|
NumFilterCalled int32
|
|
FailedNodeReturnCodeMap map[string]framework.Code
|
|
}
|
|
|
|
// Name returns name of the plugin.
|
|
func (pl *FakeFilterPlugin) Name() string {
|
|
return "FakeFilter"
|
|
}
|
|
|
|
// Filter invoked at the filter extension point.
|
|
func (pl *FakeFilterPlugin) Filter(_ context.Context, _ *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status {
|
|
atomic.AddInt32(&pl.NumFilterCalled, 1)
|
|
|
|
if returnCode, ok := pl.FailedNodeReturnCodeMap[nodeInfo.Node().Name]; ok {
|
|
return framework.NewStatus(returnCode, fmt.Sprintf("injecting failure for pod %v", pod.Name))
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
// NewFakeFilterPlugin initializes a fakeFilterPlugin and returns it.
|
|
func NewFakeFilterPlugin(failedNodeReturnCodeMap map[string]framework.Code) frameworkruntime.PluginFactory {
|
|
return func(_ runtime.Object, _ framework.Handle) (framework.Plugin, error) {
|
|
return &FakeFilterPlugin{
|
|
FailedNodeReturnCodeMap: failedNodeReturnCodeMap,
|
|
}, nil
|
|
}
|
|
}
|
|
|
|
// MatchFilterPlugin is a filter plugin which return Success when the evaluated pod and node
|
|
// have the same name; otherwise return Unschedulable.
|
|
type MatchFilterPlugin struct{}
|
|
|
|
// Name returns name of the plugin.
|
|
func (pl *MatchFilterPlugin) Name() string {
|
|
return "MatchFilter"
|
|
}
|
|
|
|
// Filter invoked at the filter extension point.
|
|
func (pl *MatchFilterPlugin) Filter(_ context.Context, _ *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status {
|
|
node := nodeInfo.Node()
|
|
if node == nil {
|
|
return framework.NewStatus(framework.Error, "node not found")
|
|
}
|
|
if pod.Name == node.Name {
|
|
return nil
|
|
}
|
|
return framework.NewStatus(framework.Unschedulable, ErrReasonFake)
|
|
}
|
|
|
|
// NewMatchFilterPlugin initializes a MatchFilterPlugin and returns it.
|
|
func NewMatchFilterPlugin(_ runtime.Object, _ framework.Handle) (framework.Plugin, error) {
|
|
return &MatchFilterPlugin{}, nil
|
|
}
|
|
|
|
// FakePreFilterPlugin is a test filter plugin.
|
|
type FakePreFilterPlugin struct {
|
|
Result *framework.PreFilterResult
|
|
Status *framework.Status
|
|
name string
|
|
}
|
|
|
|
// Name returns name of the plugin.
|
|
func (pl *FakePreFilterPlugin) Name() string {
|
|
return pl.name
|
|
}
|
|
|
|
// PreFilter invoked at the PreFilter extension point.
|
|
func (pl *FakePreFilterPlugin) PreFilter(_ context.Context, _ *framework.CycleState, pod *v1.Pod) (*framework.PreFilterResult, *framework.Status) {
|
|
return pl.Result, pl.Status
|
|
}
|
|
|
|
// PreFilterExtensions no extensions implemented by this plugin.
|
|
func (pl *FakePreFilterPlugin) PreFilterExtensions() framework.PreFilterExtensions {
|
|
return nil
|
|
}
|
|
|
|
// NewFakePreFilterPlugin initializes a fakePreFilterPlugin and returns it.
|
|
func NewFakePreFilterPlugin(name string, result *framework.PreFilterResult, status *framework.Status) frameworkruntime.PluginFactory {
|
|
return func(_ runtime.Object, _ framework.Handle) (framework.Plugin, error) {
|
|
return &FakePreFilterPlugin{
|
|
Result: result,
|
|
Status: status,
|
|
name: name,
|
|
}, nil
|
|
}
|
|
}
|
|
|
|
// FakeReservePlugin is a test reserve plugin.
|
|
type FakeReservePlugin struct {
|
|
Status *framework.Status
|
|
}
|
|
|
|
// Name returns name of the plugin.
|
|
func (pl *FakeReservePlugin) Name() string {
|
|
return "FakeReserve"
|
|
}
|
|
|
|
// Reserve invoked at the Reserve extension point.
|
|
func (pl *FakeReservePlugin) Reserve(_ context.Context, _ *framework.CycleState, _ *v1.Pod, _ string) *framework.Status {
|
|
return pl.Status
|
|
}
|
|
|
|
// Unreserve invoked at the Unreserve extension point.
|
|
func (pl *FakeReservePlugin) Unreserve(_ context.Context, _ *framework.CycleState, _ *v1.Pod, _ string) {
|
|
}
|
|
|
|
// NewFakeReservePlugin initializes a fakeReservePlugin and returns it.
|
|
func NewFakeReservePlugin(status *framework.Status) frameworkruntime.PluginFactory {
|
|
return func(_ runtime.Object, _ framework.Handle) (framework.Plugin, error) {
|
|
return &FakeReservePlugin{
|
|
Status: status,
|
|
}, nil
|
|
}
|
|
}
|
|
|
|
// FakePreBindPlugin is a test prebind plugin.
|
|
type FakePreBindPlugin struct {
|
|
Status *framework.Status
|
|
}
|
|
|
|
// Name returns name of the plugin.
|
|
func (pl *FakePreBindPlugin) Name() string {
|
|
return "FakePreBind"
|
|
}
|
|
|
|
// PreBind invoked at the PreBind extension point.
|
|
func (pl *FakePreBindPlugin) PreBind(_ context.Context, _ *framework.CycleState, _ *v1.Pod, _ string) *framework.Status {
|
|
return pl.Status
|
|
}
|
|
|
|
// NewFakePreBindPlugin initializes a fakePreBindPlugin and returns it.
|
|
func NewFakePreBindPlugin(status *framework.Status) frameworkruntime.PluginFactory {
|
|
return func(_ runtime.Object, _ framework.Handle) (framework.Plugin, error) {
|
|
return &FakePreBindPlugin{
|
|
Status: status,
|
|
}, nil
|
|
}
|
|
}
|
|
|
|
// FakePermitPlugin is a test permit plugin.
|
|
type FakePermitPlugin struct {
|
|
Status *framework.Status
|
|
Timeout time.Duration
|
|
}
|
|
|
|
// Name returns name of the plugin.
|
|
func (pl *FakePermitPlugin) Name() string {
|
|
return "FakePermit"
|
|
}
|
|
|
|
// Permit invoked at the Permit extension point.
|
|
func (pl *FakePermitPlugin) Permit(_ context.Context, _ *framework.CycleState, _ *v1.Pod, _ string) (*framework.Status, time.Duration) {
|
|
return pl.Status, pl.Timeout
|
|
}
|
|
|
|
// NewFakePermitPlugin initializes a fakePermitPlugin and returns it.
|
|
func NewFakePermitPlugin(status *framework.Status, timeout time.Duration) frameworkruntime.PluginFactory {
|
|
return func(_ runtime.Object, _ framework.Handle) (framework.Plugin, error) {
|
|
return &FakePermitPlugin{
|
|
Status: status,
|
|
Timeout: timeout,
|
|
}, nil
|
|
}
|
|
}
|
|
|
|
type FakePreScoreAndScorePlugin struct {
|
|
name string
|
|
score int64
|
|
preScoreStatus *framework.Status
|
|
scoreStatus *framework.Status
|
|
}
|
|
|
|
// Name returns name of the plugin.
|
|
func (pl *FakePreScoreAndScorePlugin) Name() string {
|
|
return pl.name
|
|
}
|
|
|
|
func (pl *FakePreScoreAndScorePlugin) Score(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) (int64, *framework.Status) {
|
|
return pl.score, pl.scoreStatus
|
|
}
|
|
|
|
func (pl *FakePreScoreAndScorePlugin) ScoreExtensions() framework.ScoreExtensions {
|
|
return nil
|
|
}
|
|
|
|
func (pl *FakePreScoreAndScorePlugin) PreScore(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodes []*v1.Node) *framework.Status {
|
|
return pl.preScoreStatus
|
|
}
|
|
|
|
func NewFakePreScoreAndScorePlugin(name string, score int64, preScoreStatus, scoreStatus *framework.Status) frameworkruntime.PluginFactory {
|
|
return func(_ runtime.Object, _ framework.Handle) (framework.Plugin, error) {
|
|
return &FakePreScoreAndScorePlugin{
|
|
name: name,
|
|
score: score,
|
|
preScoreStatus: preScoreStatus,
|
|
scoreStatus: scoreStatus,
|
|
}, nil
|
|
}
|
|
}
|