kubernetes: k8s.io/kubernetes/test/e2e/scheduling Index | Files

package scheduling

import "k8s.io/kubernetes/test/e2e/scheduling"

Index

Package Files

events.go framework.go limit_range.go nvidia-gpus.go predicates.go preemption.go priorities.go taints.go ubernetes_lite.go ubernetes_lite_volumes.go

func CreateHostPortPods Uses

func CreateHostPortPods(f *framework.Framework, id string, replicas int, expectRunning bool)

CreateHostPortPods creates RC with host port 4321

func CreateNodeSelectorPods Uses

func CreateNodeSelectorPods(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 GetNodeThatCanRunPod Uses

func GetNodeThatCanRunPod(f *framework.Framework) string

GetNodeThatCanRunPod trying to launch a pod without a label to get a node which can launch it

func OnlyAllowNodeZones Uses

func OnlyAllowNodeZones(f *framework.Framework, zoneCount int, image string)

OnlyAllowNodeZones tests that GetAllCurrentZones returns only zones with Nodes

func PodsUseStaticPVsOrFail Uses

func PodsUseStaticPVsOrFail(f *framework.Framework, podCount int, image string)

PodsUseStaticPVsOrFail Check that the pods using statically created PVs get scheduled to the same zone that the PV is in.

func SIGDescribe Uses

func SIGDescribe(text string, body func()) bool

SIGDescribe annotates the test with the SIG label.

func SetupNVIDIAGPUNode Uses

func SetupNVIDIAGPUNode(f *framework.Framework, setupResourceGatherer bool) *framework.ContainerResourceGatherer

SetupNVIDIAGPUNode install Nvidia Drivers and wait for Nvidia GPUs to be available on nodes

func SpreadRCOrFail Uses

func SpreadRCOrFail(f *framework.Framework, replicaCount int32, image string, args []string)

SpreadRCOrFail Check that the pods comprising a replication controller get spread evenly across available zones

func SpreadServiceOrFail Uses

func SpreadServiceOrFail(f *framework.Framework, replicaCount int, image string)

SpreadServiceOrFail check that the pods comprising a service get spread evenly across available zones

func StartJob Uses

func StartJob(f *framework.Framework, completions int32)

StartJob starts a simple CUDA job that requests gpu and the specified number of completions

func VerifyJobNCompletions Uses

func VerifyJobNCompletions(f *framework.Framework, completions int32)

VerifyJobNCompletions verifies that the job has completions number of successful pods

func WaitForSchedulerAfterAction Uses

func WaitForSchedulerAfterAction(f *framework.Framework, action common.Action, ns, podName string, expectSuccess bool)

WaitForSchedulerAfterAction performs the provided action and then waits for scheduler to act on the given pod.

func WaitForStableCluster Uses

func WaitForStableCluster(c clientset.Interface, masterNodes sets.String) int

WaitForStableCluster waits until all existing pods are scheduled and returns their amount.

type Resource Uses

type Resource struct {
    MilliCPU int64
    Memory   int64
}

Resource is a collection of compute resource.

Package scheduling imports 48 packages (graph) and is imported by 164 packages. Updated 2019-11-13. Refresh now. Tools for package owners.