kubernetes/pkg/scheduler/scheduler_test.go

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

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

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

// TestWithPercentageOfNodesToScore tests scheduler's PercentageOfNodesToScore is set correctly.
func TestWithPercentageOfNodesToScore(t *testing.T) { … }

// getPodFromPriorityQueue is the function used in the TestDefaultErrorFunc test to get
// the specific pod from the given priority queue. It returns the found pod in the priority queue.
func getPodFromPriorityQueue(queue *internalqueue.PriorityQueue, pod *v1.Pod) *v1.Pod { … }

func initScheduler(ctx context.Context, cache internalcache.Cache, queue internalqueue.SchedulingQueue,
	client kubernetes.Interface, informerFactory informers.SharedInformerFactory) (*Scheduler, framework.Framework, error) { … }

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

func indexByPodSpecNodeName(obj interface{ … }

func indexByPodAnnotationNodeName(obj interface{ … }

const filterWithoutEnqueueExtensions …

const fakeNode …

const fakePod …

const emptyEventsToRegister …

const errorEventsToRegister …

const queueSort …

const fakeBind …

const emptyEventExtensions …

const fakePermit …

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

// Test_UnionedGVKs tests UnionedGVKs worked with buildQueueingHintMap.
func Test_UnionedGVKs(t *testing.T) { … }

func newFramework(ctx context.Context, r frameworkruntime.Registry, profile schedulerapi.KubeSchedulerProfile) (framework.Framework, error) { … }

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

var _ …

type fakeQueueSortPlugin …

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

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

var _ …

type fakebindPlugin …

func (t *fakebindPlugin) Name() string { … }

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

type filterWithoutEnqueueExtensionsPlugin …

func (*filterWithoutEnqueueExtensionsPlugin) Name() string { … }

func (*filterWithoutEnqueueExtensionsPlugin) Filter(_ context.Context, _ *framework.CycleState, _ *v1.Pod, _ *framework.NodeInfo) *framework.Status { … }

var hintFromFakeNode …

type fakeNodePlugin …

var fakeNodePluginQueueingFn …

func (*fakeNodePlugin) Name() string { … }

func (*fakeNodePlugin) Filter(_ context.Context, _ *framework.CycleState, _ *v1.Pod, _ *framework.NodeInfo) *framework.Status { … }

func (pl *fakeNodePlugin) EventsToRegister(_ context.Context) ([]framework.ClusterEventWithHint, error) { … }

var hintFromFakePod …

type fakePodPlugin …

var fakePodPluginQueueingFn …

func (*fakePodPlugin) Name() string { … }

func (*fakePodPlugin) Filter(_ context.Context, _ *framework.CycleState, _ *v1.Pod, _ *framework.NodeInfo) *framework.Status { … }

func (pl *fakePodPlugin) EventsToRegister(_ context.Context) ([]framework.ClusterEventWithHint, error) { … }

type emptyEventPlugin …

func (*emptyEventPlugin) Name() string { … }

func (*emptyEventPlugin) Filter(_ context.Context, _ *framework.CycleState, _ *v1.Pod, _ *framework.NodeInfo) *framework.Status { … }

func (pl *emptyEventPlugin) EventsToRegister(_ context.Context) ([]framework.ClusterEventWithHint, error) { … }

type errorEventsToRegisterPlugin …

func (*errorEventsToRegisterPlugin) Name() string { … }

func (*errorEventsToRegisterPlugin) Filter(_ context.Context, _ *framework.CycleState, _ *v1.Pod, _ *framework.NodeInfo) *framework.Status { … }

func (*errorEventsToRegisterPlugin) EventsToRegister(_ context.Context) ([]framework.ClusterEventWithHint, error) { … }

type emptyEventsToRegisterPlugin …

func (*emptyEventsToRegisterPlugin) Name() string { … }

func (*emptyEventsToRegisterPlugin) Filter(_ context.Context, _ *framework.CycleState, _ *v1.Pod, _ *framework.NodeInfo) *framework.Status { … }

func (*emptyEventsToRegisterPlugin) EventsToRegister(_ context.Context) ([]framework.ClusterEventWithHint, error) { … }

type fakePermitPlugin …

func newFakePermitPlugin(eventRecorder events.EventRecorder) frameworkruntime.PluginFactory { … }

func (f fakePermitPlugin) Name() string { … }

const podWaitingReason …

const permitTimeout …

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

var _ …