package scheduling

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

Index ¶

• Variables
• func CreateHostPortPods(ctx context.Context, f *framework.Framework, id string, replicas int, expectRunning bool)
• func CreateNodeSelectorPods(ctx context.Context, f *framework.Framework, id string, replicas int, nodeSelector map[string]string, expectRunning bool) error
• func Get2NodesThatCanRunPod(ctx context.Context, f *framework.Framework) []string
• func GetNodeThatCanRunPod(ctx context.Context, f *framework.Framework) string
• func GetPodsScheduled(workerNodes sets.Set[string], pods *v1.PodList) (scheduledPods, notScheduledPods []v1.Pod)
• func SpreadRCOrFail(ctx context.Context, f *framework.Framework, replicaCount int32, zoneNames sets.Set[string], image string, args []string)
• func SpreadServiceOrFail(ctx context.Context, f *framework.Framework, replicaCount int, zoneNames sets.Set[string], image string)
• func WaitForSchedulerAfterAction(ctx context.Context, f *framework.Framework, action Action, ns, podName string, expectSuccess bool)
• func WaitForStableCluster(c clientset.Interface, workerNodes sets.Set[string]) int
• type Action
• type Resource

Variables ¶

var (

	// SIGDescribe annotates the test with the SIG label.
	SIGDescribe = framework.SIGDescribe("scheduling")
)

Functions ¶

func CreateHostPortPods ¶

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

CreateHostPortPods creates RC with host port 4321

func CreateNodeSelectorPods ¶

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 ¶

func Get2NodesThatCanRunPod(ctx context.Context, f *framework.Framework) []string

Get2NodesThatCanRunPod return a 2-node slice where can run pod.

func GetNodeThatCanRunPod ¶

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 ¶

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 SpreadRCOrFail ¶

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 ¶

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 WaitForSchedulerAfterAction ¶

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 ¶

func WaitForStableCluster(c clientset.Interface, workerNodes sets.Set[string]) int

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

Types ¶

type Action ¶

type Action func(ctx context.Context) error

Action is a function to be performed by the system.

type Resource ¶

type Resource struct {
	MilliCPU int64
	Memory   int64
}

Resource is a collection of compute resource.

Source Files ¶

events.go framework.go limit_range.go predicates.go preemption.go priorities.go ubernetes_lite.go