kubernetes/pkg/scheduler/framework/runtime/framework_test.go

const preEnqueuePlugin …

const queueSortPlugin …

const scoreWithNormalizePlugin1 …

const scoreWithNormalizePlugin2 …

const scorePlugin1 …

const scorePlugin2 …

const pluginNotImplementingScore …

const preFilterPluginName …

const preFilterWithExtensionsPluginName …

const duplicatePluginName …

const testPlugin …

const permitPlugin …

const bindPlugin …

const testCloseErrorPlugin …

const testProfileName …

const testPercentageOfNodesToScore …

const nodeName …

const injectReason …

const injectFilterReason …

var _ …

var _ …

var cmpOpts …

func newScoreWithNormalizePlugin1(_ context.Context, injArgs runtime.Object, f framework.Handle) (framework.Plugin, error) { … }

func newScoreWithNormalizePlugin2(_ context.Context, injArgs runtime.Object, f framework.Handle) (framework.Plugin, error) { … }

func newScorePlugin1(_ context.Context, injArgs runtime.Object, f framework.Handle) (framework.Plugin, error) { … }

func newScorePlugin2(_ context.Context, injArgs runtime.Object, f framework.Handle) (framework.Plugin, error) { … }

func newPluginNotImplementingScore(_ context.Context, _ runtime.Object, _ framework.Handle) (framework.Plugin, error) { … }

type TestScoreWithNormalizePlugin …

func (pl *TestScoreWithNormalizePlugin) Name() string { … }

func (pl *TestScoreWithNormalizePlugin) NormalizeScore(ctx context.Context, state *framework.CycleState, pod *v1.Pod, scores framework.NodeScoreList) *framework.Status { … }

func (pl *TestScoreWithNormalizePlugin) Score(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) (int64, *framework.Status) { … }

func (pl *TestScoreWithNormalizePlugin) ScoreExtensions() framework.ScoreExtensions { … }

type TestScorePlugin …

func (pl *TestScorePlugin) Name() string { … }

func (pl *TestScorePlugin) PreScore(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodes []*framework.NodeInfo) *framework.Status { … }

func (pl *TestScorePlugin) Score(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) (int64, *framework.Status) { … }

func (pl *TestScorePlugin) ScoreExtensions() framework.ScoreExtensions { … }

type PluginNotImplementingScore …

func (pl *PluginNotImplementingScore) Name() string { … }

func newTestPlugin(_ context.Context, injArgs runtime.Object, f framework.Handle) (framework.Plugin, error) { … }

type TestPlugin …

func (pl *TestPlugin) AddPod(ctx context.Context, state *framework.CycleState, podToSchedule *v1.Pod, podInfoToAdd *framework.PodInfo, nodeInfo *framework.NodeInfo) *framework.Status { … }

func (pl *TestPlugin) RemovePod(ctx context.Context, state *framework.CycleState, podToSchedule *v1.Pod, podInfoToRemove *framework.PodInfo, nodeInfo *framework.NodeInfo) *framework.Status { … }

func (pl *TestPlugin) Name() string { … }

func (pl *TestPlugin) Less(*framework.QueuedPodInfo, *framework.QueuedPodInfo) bool { … }

func (pl *TestPlugin) Score(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) (int64, *framework.Status) { … }

func (pl *TestPlugin) ScoreExtensions() framework.ScoreExtensions { … }

func (pl *TestPlugin) PreFilter(ctx context.Context, state *framework.CycleState, p *v1.Pod) (*framework.PreFilterResult, *framework.Status) { … }

func (pl *TestPlugin) PreFilterExtensions() framework.PreFilterExtensions { … }

func (pl *TestPlugin) Filter(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status { … }

func (pl *TestPlugin) PostFilter(_ context.Context, _ *framework.CycleState, _ *v1.Pod, _ framework.NodeToStatusReader) (*framework.PostFilterResult, *framework.Status) { … }

func (pl *TestPlugin) PreScore(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodes []*framework.NodeInfo) *framework.Status { … }

func (pl *TestPlugin) Reserve(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) *framework.Status { … }

func (pl *TestPlugin) Unreserve(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) { … }

func (pl *TestPlugin) PreBind(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) *framework.Status { … }

func (pl *TestPlugin) PostBind(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) { … }

func (pl *TestPlugin) Permit(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) (*framework.Status, time.Duration) { … }

func (pl *TestPlugin) Bind(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) *framework.Status { … }

func newTestCloseErrorPlugin(_ context.Context, injArgs runtime.Object, f framework.Handle) (framework.Plugin, error) { … }

type TestCloseErrorPlugin …

func (pl *TestCloseErrorPlugin) Name() string { … }

var errClose …

func (pl *TestCloseErrorPlugin) Close() error { … }

type TestPreFilterPlugin …

func (pl *TestPreFilterPlugin) Name() string { … }

func (pl *TestPreFilterPlugin) PreFilter(ctx context.Context, state *framework.CycleState, p *v1.Pod) (*framework.PreFilterResult, *framework.Status) { … }

func (pl *TestPreFilterPlugin) PreFilterExtensions() framework.PreFilterExtensions { … }

type TestPreFilterWithExtensionsPlugin …

func (pl *TestPreFilterWithExtensionsPlugin) Name() string { … }

func (pl *TestPreFilterWithExtensionsPlugin) PreFilter(ctx context.Context, state *framework.CycleState, p *v1.Pod) (*framework.PreFilterResult, *framework.Status) { … }

func (pl *TestPreFilterWithExtensionsPlugin) AddPod(ctx context.Context, state *framework.CycleState, podToSchedule *v1.Pod,
	podInfoToAdd *framework.PodInfo, nodeInfo *framework.NodeInfo) *framework.Status { … }

func (pl *TestPreFilterWithExtensionsPlugin) RemovePod(ctx context.Context, state *framework.CycleState, podToSchedule *v1.Pod,
	podInfoToRemove *framework.PodInfo, nodeInfo *framework.NodeInfo) *framework.Status { … }

func (pl *TestPreFilterWithExtensionsPlugin) PreFilterExtensions() framework.PreFilterExtensions { … }

type TestDuplicatePlugin …

func (dp *TestDuplicatePlugin) Name() string { … }

func (dp *TestDuplicatePlugin) PreFilter(ctx context.Context, state *framework.CycleState, p *v1.Pod) (*framework.PreFilterResult, *framework.Status) { … }

func (dp *TestDuplicatePlugin) PreFilterExtensions() framework.PreFilterExtensions { … }

var _ …

func newDuplicatePlugin(_ context.Context, _ runtime.Object, _ framework.Handle) (framework.Plugin, error) { … }

type TestPermitPlugin …

func (pp *TestPermitPlugin) Name() string { … }

func (pp *TestPermitPlugin) Permit(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) (*framework.Status, time.Duration) { … }

var _ …

type TestPreEnqueuePlugin …

func (pl *TestPreEnqueuePlugin) Name() string { … }

func (pl *TestPreEnqueuePlugin) PreEnqueue(ctx context.Context, p *v1.Pod) *framework.Status { … }

var _ …

func newQueueSortPlugin(_ context.Context, _ runtime.Object, _ framework.Handle) (framework.Plugin, error) { … }

type TestQueueSortPlugin …

func (pl *TestQueueSortPlugin) Name() string { … }

func (pl *TestQueueSortPlugin) Less(_, _ *framework.QueuedPodInfo) bool { … }

var _ …

func newBindPlugin(_ context.Context, _ runtime.Object, _ framework.Handle) (framework.Plugin, error) { … }

type TestBindPlugin …

func (t TestBindPlugin) Name() string { … }

func (t TestBindPlugin) Bind(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) *framework.Status { … }

var registry …

var defaultWeights …

var state …

var pod …

var node …

var (
	lowPriority …
	highPriority …
)

var lowPriorityPod …

var highPriorityPod …

var nodes …

var errInjectedStatus …

var errInjectedFilterStatus …

func newFrameworkWithQueueSortAndBind(ctx context.Context, r Registry, profile config.KubeSchedulerProfile, opts ...Option) (framework.Framework, error) { … }

func TestInitFrameworkWithScorePlugins(t *testing.T) { … }

func TestNewFrameworkErrors(t *testing.T) { … }

func TestNewFrameworkMultiPointExpansion(t *testing.T) { … }

func TestPreEnqueuePlugins(t *testing.T) { … }

func TestRunPreScorePlugins(t *testing.T) { … }

func TestRunScorePlugins(t *testing.T) { … }

func TestPreFilterPlugins(t *testing.T) { … }

func TestRunPreFilterPlugins(t *testing.T) { … }

func TestRunPreFilterExtensionRemovePod(t *testing.T) { … }

func TestRunPreFilterExtensionAddPod(t *testing.T) { … }

func TestFilterPlugins(t *testing.T) { … }

func TestPostFilterPlugins(t *testing.T) { … }

func TestFilterPluginsWithNominatedPods(t *testing.T) { … }

func TestPreBindPlugins(t *testing.T) { … }

func TestReservePlugins(t *testing.T) { … }

func TestPermitPlugins(t *testing.T) { … }

// withMetricsRecorder set metricsRecorder for the scheduling frameworkImpl.
func withMetricsRecorder(recorder *metrics.MetricAsyncRecorder) Option { … }

func TestRecordingMetrics(t *testing.T) { … }

func TestRunBindPlugins(t *testing.T) { … }

func TestPermitWaitDurationMetric(t *testing.T) { … }

func TestWaitOnPermit(t *testing.T) { … }

func TestListPlugins(t *testing.T) { … }

func TestClose(t *testing.T) { … }

func buildScoreConfigDefaultWeights(ps ...string) *config.Plugins { … }

func buildScoreConfigWithWeights(weights map[string]int32, ps ...string) *config.Plugins { … }

type injectedResult …

func setScoreRes(inj injectedResult) (int64, *framework.Status) { … }

func injectNormalizeRes(inj injectedResult, scores framework.NodeScoreList) *framework.Status { … }

func collectAndComparePluginMetrics(t *testing.T, wantExtensionPoint, wantPlugin string, wantStatus framework.Code) { … }

func collectAndCompareFrameworkMetrics(t *testing.T, wantExtensionPoint string, wantStatus framework.Code) { … }

func collectAndComparePermitWaitDuration(t *testing.T, wantRes string) { … }

func mustNewPodInfo(t *testing.T, pod *v1.Pod) *framework.PodInfo { … }

// BuildNodeInfos build NodeInfo slice from a v1.Node slice
func BuildNodeInfos(nodes []*v1.Node) []*framework.NodeInfo { … }