wait

Documentation

Index

• func AreDaemonSetPodsReady(newStatus *appsv1.DaemonSetStatus) bool
• func AreDeploymentReplicasAvailable(newStatus *appsv1.DeploymentStatus, replicas int32) bool
• func AreReplicasAvailable(newStatus *appsv1.ReplicaSetStatus, replicas int32) 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 *nropv1alpha1.NUMAResourcesOperator, ...) (*nropv1alpha1.NUMAResourcesOperator, error)
• func ForDeploymentComplete(cli client.Client, dp *appsv1.Deployment, ...) (*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 *nropv1alpha1.NUMAResourcesOperator, ...) error
• func ForNUMAResourcesSchedulerDeleted(cli client.Client, nrSched *nropv1alpha1.NUMAResourcesScheduler, ...) error
• func ForPodDeleted(cli client.Client, podNamespace, podName string, timeout time.Duration) error
• func ForPodListAllRunning(cli client.Client, pods []*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 IsReplicasetComplete(rs *appsv1.ReplicaSet, newStatus *appsv1.ReplicaSetStatus) 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

Functions

func AreDaemonSetPodsReady

func AreDaemonSetPodsReady(newStatus *appsv1.DaemonSetStatus) bool

func AreDeploymentReplicasAvailable

func AreDeploymentReplicasAvailable(newStatus *appsv1.DeploymentStatus, replicas int32) bool

func AreReplicasAvailable

func AreReplicasAvailable(newStatus *appsv1.ReplicaSetStatus, replicas int32) 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 *nropv1alpha1.NUMAResourcesOperator, interval time.Duration, timeout time.Duration) (*nropv1alpha1.NUMAResourcesOperator, error)

func ForDeploymentComplete

func ForDeploymentComplete(cli client.Client, dp *appsv1.Deployment, 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 *nropv1alpha1.NUMAResourcesOperator, pollInterval, pollTimeout time.Duration) error

func ForNUMAResourcesSchedulerDeleted

func ForNUMAResourcesSchedulerDeleted(cli client.Client, nrSched *nropv1alpha1.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) []*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 IsReplicasetComplete

func IsReplicasetComplete(rs *appsv1.ReplicaSet, newStatus *appsv1.ReplicaSetStatus) 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