wait

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

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

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

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

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

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

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

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 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, pods []*v1.Pod)

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

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

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

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

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

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

func PatchSystemDeploymentFeatureFlags(
	ctx context.Context,
	kubeClientset kubernetes.Interface,
	controllerClient runtimeClient.WithWatch,
	namespace string,
	deploymentName string,
	containerName string,
	featureFlagsUpdater ArgsUpdater,
) error

func UpateDeploymentReplicas(
	ctx context.Context,
	clientset kubernetes.Interface,
	namespace string,
	name string,
	replicas int32,
) error

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

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

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

func WaitForPodGroupsToBeReady(
	ctx context.Context,
	kubeClientset *kubernetes.Clientset,
	runaiClientset *runaiClient.Clientset,
	controllerClient runtimeClient.WithWatch,
	namespace string,
	numPodGroups int)