var (
// SIGDescribe annotates the test with the SIG label.
SIGDescribe = framework.SIGDescribe("scheduling")
)
func CreateHostPortPods(ctx context.Context, f *framework.Framework, id string, replicas int, expectRunning bool)
CreateHostPortPods creates RC with host port 4321
func CreateNodeSelectorPods(ctx context.Context, f *framework.Framework, id string, replicas int, nodeSelector map[string]string, expectRunning bool) error
CreateNodeSelectorPods creates RC with host port 4321 and defines node selector
func Get2NodesThatCanRunPod(ctx context.Context, f *framework.Framework) []string
Get2NodesThatCanRunPod return a 2-node slice where can run pod.
func GetNodeThatCanRunPod(ctx context.Context, f *framework.Framework) string
GetNodeThatCanRunPod trying to launch a pod without a label to get a node which can launch it
func GetPodsScheduled(workerNodes sets.Set[string], pods *v1.PodList) (scheduledPods, notScheduledPods []v1.Pod)
GetPodsScheduled returns a number of currently scheduled and not scheduled Pods on worker nodes.
func SetupNVIDIAGPUNode(ctx context.Context, f *framework.Framework, setupResourceGatherer bool) *e2edebug.ContainerResourceGatherer
SetupNVIDIAGPUNode install Nvidia Drivers and wait for Nvidia GPUs to be available on nodes
func SpreadRCOrFail(ctx context.Context, f *framework.Framework, replicaCount int32, zoneNames sets.Set[string], image string, args []string)
SpreadRCOrFail Check that the pods comprising a replication controller get spread evenly across available zones
func SpreadServiceOrFail(ctx context.Context, f *framework.Framework, replicaCount int, zoneNames sets.Set[string], image string)
SpreadServiceOrFail check that the pods comprising a service get spread evenly across available zones
func StartJob(ctx context.Context, f *framework.Framework, completions int32)
StartJob starts a simple CUDA job that requests gpu and the specified number of completions
func VerifyJobNCompletions(ctx context.Context, f *framework.Framework, completions int32)
VerifyJobNCompletions verifies that the job has completions number of successful pods
func WaitForSchedulerAfterAction(ctx context.Context, f *framework.Framework, action Action, ns, podName string, expectSuccess bool)
WaitForSchedulerAfterAction performs the provided action and then waits for scheduler to act on the given pod.
func WaitForStableCluster(c clientset.Interface, workerNodes sets.Set[string]) int
WaitForStableCluster waits until all existing pods are scheduled and returns their amount.
Action is a function to be performed by the system.
type Action func(ctx context.Context) error
Resource is a collection of compute resource.
type Resource struct {
MilliCPU int64
Memory int64
}