wait

package

v0.4.13-0 Latest Latest Go to latest Published: Apr 27, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation ¶

Index ¶

Constants
func AreDaemonSetPodsReady(newStatus *appsv1.DaemonSetStatus) bool
func ForDaemonSetReady(cli client.Client, ds *appsv1.DaemonSet, ...) (*appsv1.DaemonSet, error)
func ForDaemonSetReadyByKey(cli client.Client, key ObjectKey, pollInterval, pollTimeout time.Duration) (*appsv1.DaemonSet, error)
func ForDaemonsetInNUMAResourcesOperatorStatus(cli client.Client, nroObj *nropv1.NUMAResourcesOperator, ...) (*nropv1.NUMAResourcesOperator, error)
func ForDaemonsetPodsCreation(cli client.Client, ds *appsv1.DaemonSet, expectedPods int, ...) (*appsv1.DaemonSet, error)
func ForDeploymentComplete(cli client.Client, dp *appsv1.Deployment, ...) (*appsv1.Deployment, error)
func ForDeploymentReplicasCreation(cli client.Client, dp *appsv1.Deployment, expectedReplicas int32, ...) (*appsv1.Deployment, error)
func ForKubeletConfigDeleted(cli client.Client, kc *machineconfigv1.KubeletConfig, ...) error
func ForMachineConfigPoolCondition(cli client.Client, mcp *machineconfigv1.MachineConfigPool, ...) error
func ForMachineConfigPoolDeleted(cli client.Client, mcp *machineconfigv1.MachineConfigPool, ...) error
func ForNUMAResourcesOperatorDeleted(cli client.Client, nrop *nropv1.NUMAResourcesOperator, ...) error
func ForNUMAResourcesSchedulerDeleted(cli client.Client, nrSched *nropv1.NUMAResourcesScheduler, ...) error
func ForPodDeleted(cli client.Client, podNamespace, podName string, timeout time.Duration) error
func ForPodListAllRunning(cli client.Client, pods []*corev1.Pod, timeout time.Duration) ([]*corev1.Pod, []*corev1.Pod)
func ForPodPhase(cli client.Client, podNamespace, podName string, phase corev1.PodPhase, ...) (*corev1.Pod, error)
func ForReplicasetComplete(cli client.Client, rs *appsv1.ReplicaSet, ...) (*appsv1.ReplicaSet, error)
func IsDeploymentComplete(dp *appsv1.Deployment, newStatus *appsv1.DeploymentStatus) bool
func WhileInPodPhase(cli client.Client, podNamespace, podName string, phase corev1.PodPhase, ...) error
type ObjectKey
- func ObjectKeyFromObject(obj metav1.Object) ObjectKey
- func (ok ObjectKey) AsKey() types.NamespacedName
- func (ok ObjectKey) String() string

Constants ¶

const (
	// DefaultPodRunningTimeout was computed by trial and error, not scientifically,
	// so it may adjusted in the future any time.
	DefaultPodRunningTimeout = 3 * time.Minute
)

Variables ¶

This section is empty.

Functions ¶

func AreDaemonSetPodsReady ¶

func AreDaemonSetPodsReady(newStatus *appsv1.DaemonSetStatus) bool

func ForDaemonSetReady ¶

func ForDaemonSetReady(cli client.Client, ds *appsv1.DaemonSet, pollInterval, pollTimeout time.Duration) (*appsv1.DaemonSet, error)

func ForDaemonSetReadyByKey ¶

func ForDaemonSetReadyByKey(cli client.Client, key ObjectKey, pollInterval, pollTimeout time.Duration) (*appsv1.DaemonSet, error)

func ForDaemonsetInNUMAResourcesOperatorStatus ¶

func ForDaemonsetInNUMAResourcesOperatorStatus(cli client.Client, nroObj *nropv1.NUMAResourcesOperator, interval time.Duration, timeout time.Duration) (*nropv1.NUMAResourcesOperator, error)

func ForDaemonsetPodsCreation ¶

func ForDaemonsetPodsCreation(cli client.Client, ds *appsv1.DaemonSet, expectedPods int, pollInterval, pollTimeout time.Duration) (*appsv1.DaemonSet, error)

func ForDeploymentComplete ¶

func ForDeploymentComplete(cli client.Client, dp *appsv1.Deployment, pollInterval, pollTimeout time.Duration) (*appsv1.Deployment, error)

func ForDeploymentReplicasCreation ¶

func ForDeploymentReplicasCreation(cli client.Client, dp *appsv1.Deployment, expectedReplicas int32, pollInterval, pollTimeout time.Duration) (*appsv1.Deployment, error)

func ForKubeletConfigDeleted ¶

func ForKubeletConfigDeleted(cli client.Client, kc *machineconfigv1.KubeletConfig, pollInterval, pollTimeout time.Duration) error

func ForMachineConfigPoolCondition ¶

func ForMachineConfigPoolCondition(cli client.Client, mcp *machineconfigv1.MachineConfigPool, condType machineconfigv1.MachineConfigPoolConditionType, pollInterval, pollTimeout time.Duration) error

func ForMachineConfigPoolDeleted ¶

func ForMachineConfigPoolDeleted(cli client.Client, mcp *machineconfigv1.MachineConfigPool, pollInterval, pollTimeout time.Duration) error

func ForNUMAResourcesOperatorDeleted ¶

func ForNUMAResourcesOperatorDeleted(cli client.Client, nrop *nropv1.NUMAResourcesOperator, pollInterval, pollTimeout time.Duration) error

func ForNUMAResourcesSchedulerDeleted ¶

func ForNUMAResourcesSchedulerDeleted(cli client.Client, nrSched *nropv1.NUMAResourcesScheduler, pollInterval, pollTimeout time.Duration) error

func ForPodDeleted ¶

func ForPodDeleted(cli client.Client, podNamespace, podName string, timeout time.Duration) error

func ForPodListAllRunning ¶

func ForPodListAllRunning(cli client.Client, pods []*corev1.Pod, timeout time.Duration) ([]*corev1.Pod, []*corev1.Pod)

func ForPodPhase ¶

func ForPodPhase(cli client.Client, podNamespace, podName string, phase corev1.PodPhase, timeout time.Duration) (*corev1.Pod, error)

func ForReplicasetComplete ¶

func ForReplicasetComplete(cli client.Client, rs *appsv1.ReplicaSet, pollInterval, pollTimeout time.Duration) (*appsv1.ReplicaSet, error)

func IsDeploymentComplete ¶

func IsDeploymentComplete(dp *appsv1.Deployment, newStatus *appsv1.DeploymentStatus) bool

func WhileInPodPhase ¶

func WhileInPodPhase(cli client.Client, podNamespace, podName string, phase corev1.PodPhase, interval time.Duration, steps int) error

Types ¶

type ObjectKey ¶

type ObjectKey struct {
	Namespace string
	Name      string
}

func ObjectKeyFromObject ¶

func ObjectKeyFromObject(obj metav1.Object) ObjectKey

func (ObjectKey) AsKey ¶

func (ok ObjectKey) AsKey() types.NamespacedName

func (ObjectKey) String ¶

func (ok ObjectKey) String() string

Source Files ¶

View all Source files

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