kubernetes/test/e2e/scheduling/preemption.go

type priorityPair …

var testExtendedResource …

const testFinalizer …

var _ …

type pauseRSConfig …

func initPauseRS(f *framework.Framework, conf pauseRSConfig) *appsv1.ReplicaSet { … }

func createPauseRS(ctx context.Context, f *framework.Framework, conf pauseRSConfig) *appsv1.ReplicaSet { … }

func runPauseRS(ctx context.Context, f *framework.Framework, conf pauseRSConfig) *appsv1.ReplicaSet { … }

func createPod(ctx context.Context, f *framework.Framework, conf pausePodConfig) *v1.Pod { … }

// waitForPreemptingWithTimeout verifies if 'pod' is preempting within 'timeout', specifically it checks
// if the 'spec.NodeName' field of preemptor 'pod' has been set.
func waitForPreemptingWithTimeout(ctx context.Context, f *framework.Framework, pod *v1.Pod, timeout time.Duration) { … }

func patchNode(ctx context.Context, client clientset.Interface, old *v1.Node, new *v1.Node) error { … }

func patchPriorityClass(ctx context.Context, cs clientset.Interface, old, new *schedulingv1.PriorityClass) error { … }