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 {}