wait

package

v0.13.0 Latest Latest Go to latest Published: Mar 2, 2026 License: Apache-2.0 Imports: 24 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/NVIDIA/KAI-scheduler

Links

Documentation ¶

Overview ¶

Index ¶

func ForAtLeastNNodes(ctx context.Context, client runtimeClient.WithWatch, ...)
func ForAtLeastNPodCreation(ctx context.Context, client runtimeClient.WithWatch, ...)
func ForAtLeastNPodsScheduled(ctx context.Context, client runtimeClient.WithWatch, namespace string, ...)
func ForAtLeastNPodsUnschedulable(ctx context.Context, client runtimeClient.WithWatch, namespace string, ...)
func ForAtLeastOnePodCreation(ctx context.Context, client runtimeClient.WithWatch, ...)
func ForConfigMapCreation(ctx context.Context, client runtimeClient.WithWatch, namespace, name string)
func ForExactlyNKWOKOperatorNodePools(ctx context.Context, client runtimeClient.WithWatch, ...)
func ForGPUOPeratorUpdateOnKWOKNodes(ctx context.Context, client runtimeClient.WithWatch, ...)
func ForKAIConfigStatusOK(ctx context.Context, runtimeClient client.Client)
func ForKAIConfigStatusOKWithTimeout(ctx context.Context, runtimeClient client.Client, timeout time.Duration)
func ForKWOKOperatorNodePool(ctx context.Context, client runtimeClient.WithWatch, nodePoolName string)
func ForKaiComponentPod(ctx context.Context, client runtimeClient.WithWatch, ...)
func ForNamespacesToBeDeleted(ctx context.Context, client runtimeClient.WithWatch, namespaces []string)
func ForNoE2EPods(ctx context.Context, client runtimeClient.WithWatch)
func ForNoReservationPods(ctx context.Context, client runtimeClient.WithWatch)
func ForPodCountInNamespace(ctx context.Context, client runtimeClient.WithWatch, q *v2.Queue, ...)
func ForPodGroupNotReadyEvent(ctx context.Context, client runtimeClient.WithWatch, namespace, name string)
func ForPodReady(ctx context.Context, client runtimeClient.WithWatch, pod *v1.Pod)
func ForPodScheduled(ctx context.Context, client runtimeClient.WithWatch, pod *v1.Pod)
func ForPodSucceeded(ctx context.Context, client runtimeClient.WithWatch, pod *v1.Pod)
func ForPodSucceededOrError(ctx context.Context, client runtimeClient.WithWatch, pod *v1.Pod)
func ForPodUnschedulable(ctx context.Context, client runtimeClient.WithWatch, pod *v1.Pod)
func ForPodsReady(ctx context.Context, client runtimeClient.WithWatch, namespace string, ...)
func ForPodsScheduled(ctx context.Context, client runtimeClient.WithWatch, namespace string, ...)
func ForPodsToBeDeleted(ctx context.Context, client runtimeClient.WithWatch, ...)
func ForPodsWithCondition(ctx context.Context, client runtimeClient.WithWatch, ...)
func ForRolloutRestartDeployment(ctx context.Context, client runtimeClient.WithWatch, namespace, name string) error
func ForRunningSystemComponentEvent(ctx context.Context, client runtimeClient.WithWatch, ...)
func ForSchedulingShardStatusOK(ctx context.Context, runtimeClient client.Client, shardName string)
func ForSchedulingShardStatusOKWithTimeout(ctx context.Context, runtimeClient client.Client, shardName string, ...)
func ForZeroKWOKNodes(ctx context.Context, client runtimeClient.WithWatch)
func WaitForDeploymentPodsRunning(ctx context.Context, client runtimeClient.WithWatch, name, namespace string)
func WaitForEventInNamespace(ctx context.Context, client runtimeClient.WithWatch, namespace string, ...) bool
func WaitForEventInNamespaceAndPod(ctx context.Context, client runtimeClient.WithWatch, namespace string, ...) bool
func WaitForPodGroupToExist(ctx context.Context, client runtimeClient.WithWatch, namespace, name string)
func WaitForPodGroupsToBeReady(ctx context.Context, controllerClient runtimeClient.WithWatch, ...)
type ArgsUpdater

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ForAtLeastNNodes ¶ added in v0.13.0

func ForAtLeastNNodes(
	ctx context.Context, client runtimeClient.WithWatch, nodeLabels map[string]string, n int,
)

func ForAtLeastNPodCreation ¶

func ForAtLeastNPodCreation(ctx context.Context, client runtimeClient.WithWatch, selector metav1.LabelSelector, n int)

func ForAtLeastNPodsScheduled ¶

func ForAtLeastNPodsScheduled(ctx context.Context, client runtimeClient.WithWatch, namespace string,
	pods []*v1.Pod, minRequired int)

func ForAtLeastNPodsUnschedulable ¶

func ForAtLeastNPodsUnschedulable(ctx context.Context, client runtimeClient.WithWatch, namespace string,
	pods []*v1.Pod, minRequired int)

func ForAtLeastOnePodCreation ¶

func ForAtLeastOnePodCreation(ctx context.Context, client runtimeClient.WithWatch, selector metav1.LabelSelector)

func ForConfigMapCreation ¶

func ForConfigMapCreation(ctx context.Context, client runtimeClient.WithWatch, namespace, name string)

func ForExactlyNKWOKOperatorNodePools ¶ added in v0.13.0

func ForExactlyNKWOKOperatorNodePools(
	ctx context.Context, client runtimeClient.WithWatch, nodePoolLabels map[string]string, n int,
)

func ForGPUOPeratorUpdateOnKWOKNodes ¶ added in v0.13.0

func ForGPUOPeratorUpdateOnKWOKNodes(
	ctx context.Context, client runtimeClient.WithWatch, numberOfNodes, gpusPerNode int,
)

func ForKAIConfigStatusOK ¶ added in v0.12.19

func ForKAIConfigStatusOK(ctx context.Context, runtimeClient client.Client)

ForKAIConfigStatusOK waits until the KAIConfig singleton has all status conditions (Deployed, Available, DependenciesFulfilled) set to True for the current generation.

func ForKAIConfigStatusOKWithTimeout ¶ added in v0.12.19

func ForKAIConfigStatusOKWithTimeout(ctx context.Context, runtimeClient client.Client, timeout time.Duration)

ForKAIConfigStatusOKWithTimeout waits until the KAIConfig singleton has all status conditions healthy, with a custom timeout.

func ForKWOKOperatorNodePool ¶ added in v0.13.0

func ForKWOKOperatorNodePool(
	ctx context.Context, client runtimeClient.WithWatch, nodePoolName string,
)

func ForKaiComponentPod ¶ added in v0.6.0

func ForKaiComponentPod(
	ctx context.Context, client runtimeClient.WithWatch,
	appLabelComponentName string, condition checkCondition,
)

func ForNamespacesToBeDeleted ¶ added in v0.10.0

func ForNamespacesToBeDeleted(ctx context.Context, client runtimeClient.WithWatch, namespaces []string)

ForNamespacesToBeDeleted waits for all specified namespaces to be deleted (not exist in the cluster). It takes a list of namespace names and waits until none of them exist.

func ForNoE2EPods ¶

func ForNoE2EPods(ctx context.Context, client runtimeClient.WithWatch)

func ForNoReservationPods ¶

func ForNoReservationPods(ctx context.Context, client runtimeClient.WithWatch)

func ForPodCountInNamespace ¶ added in v0.12.12

func ForPodCountInNamespace(ctx context.Context, client runtimeClient.WithWatch, q *v2.Queue, expectedPodCount int, waitTime time.Duration)

func ForPodGroupNotReadyEvent ¶

func ForPodGroupNotReadyEvent(ctx context.Context, client runtimeClient.WithWatch, namespace, name string)

func ForPodReady ¶

func ForPodReady(ctx context.Context, client runtimeClient.WithWatch, pod *v1.Pod)

func ForPodScheduled ¶

func ForPodScheduled(ctx context.Context, client runtimeClient.WithWatch, pod *v1.Pod)

func ForPodSucceeded ¶ added in v0.13.0

func ForPodSucceeded(ctx context.Context, client runtimeClient.WithWatch, pod *v1.Pod)

func ForPodSucceededOrError ¶

func ForPodSucceededOrError(ctx context.Context, client runtimeClient.WithWatch, pod *v1.Pod)

func ForPodUnschedulable ¶

func ForPodUnschedulable(ctx context.Context, client runtimeClient.WithWatch, pod *v1.Pod)

func ForPodsReady ¶

func ForPodsReady(ctx context.Context, client runtimeClient.WithWatch, namespace string, pods []*v1.Pod)

func ForPodsScheduled ¶

func ForPodsScheduled(ctx context.Context, client runtimeClient.WithWatch, namespace string, pods []*v1.Pod)

func ForPodsToBeDeleted ¶

func ForPodsToBeDeleted(ctx context.Context, client runtimeClient.WithWatch, listOptions ...runtimeClient.ListOption)

func ForPodsWithCondition ¶

func ForPodsWithCondition(
	ctx context.Context, client runtimeClient.WithWatch, checkCondition checkCondition,
	listOptions ...runtimeClient.ListOption)

func ForRolloutRestartDeployment ¶

func ForRolloutRestartDeployment(ctx context.Context, client runtimeClient.WithWatch, namespace, name string) error

func ForRunningSystemComponentEvent ¶

func ForRunningSystemComponentEvent(ctx context.Context, client runtimeClient.WithWatch, appLabelComponentName string)

func ForSchedulingShardStatusOK ¶ added in v0.13.0

func ForSchedulingShardStatusOK(ctx context.Context, runtimeClient client.Client, shardName string)

ForSchedulingShardStatusOK waits until the given SchedulingShard has all status conditions (Deployed, Available, DependenciesFulfilled) set to True for the current generation.

func ForSchedulingShardStatusOKWithTimeout ¶ added in v0.13.0

func ForSchedulingShardStatusOKWithTimeout(ctx context.Context, runtimeClient client.Client, shardName string, timeout time.Duration)

ForSchedulingShardStatusOKWithTimeout waits until the given SchedulingShard has all status conditions healthy, with a custom timeout.

func ForZeroKWOKNodes ¶ added in v0.13.0

func ForZeroKWOKNodes(
	ctx context.Context, client runtimeClient.WithWatch,
)

func WaitForDeploymentPodsRunning ¶

func WaitForDeploymentPodsRunning(ctx context.Context, client runtimeClient.WithWatch, name, namespace string)

WaitForDeploymentPodsRunning waits until all pods from a deployment are in the running state

func WaitForEventInNamespace ¶

func WaitForEventInNamespace(ctx context.Context, client runtimeClient.WithWatch,
	namespace string, checkCondition checkEventCondition) bool

func WaitForEventInNamespaceAndPod ¶

func WaitForEventInNamespaceAndPod(ctx context.Context, client runtimeClient.WithWatch,
	namespace string, podName string, checkCondition checkEventCondition) bool

func WaitForPodGroupToExist ¶ added in v0.9.0

func WaitForPodGroupToExist(
	ctx context.Context,
	client runtimeClient.WithWatch,
	namespace, name string,
)

func WaitForPodGroupsToBeReady ¶

func WaitForPodGroupsToBeReady(
	ctx context.Context,
	controllerClient runtimeClient.WithWatch,
	namespace string,
	numPodGroups int)

Types ¶

type ArgsUpdater ¶

type ArgsUpdater func(args []string) []string

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
watcher

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL