func TestSchedulerCreation(t *testing.T) { … }
func TestFailureHandler(t *testing.T) { … }
func TestFailureHandler_PodAlreadyBound(t *testing.T) { … }
func TestWithPercentageOfNodesToScore(t *testing.T) { … }
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) { … }
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 _ …