wait

Documentation

Index

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

Constants

const (
	DefaultPollInterval = 1 * time.Second
	// DefaultPollTimeout was computed by trial and error, not scientifically,
	// so it may adjusted in the future any time.
	// Roughly match the time it takes for pods to go running in CI.
	DefaultPollTimeout = 3 * time.Minute
)

Functions

func AreDaemonSetPodsReady

func AreDaemonSetPodsReady(newStatus *appsv1.DaemonSetStatus) bool

func IsDeploymentComplete

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

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

type Waiter

type Waiter struct {
	Cli          client.Client
	PollTimeout  time.Duration
	PollInterval time.Duration
	PollSteps    int // alternative to Timeout
}

func With

func With(cli client.Client) *Waiter

func (Waiter) ForDaemonSetReady

func (wt Waiter) ForDaemonSetReady(ctx context.Context, ds *appsv1.DaemonSet) (*appsv1.DaemonSet, error)

func (Waiter) ForDaemonSetReadyByKey

func (wt Waiter) ForDaemonSetReadyByKey(ctx context.Context, key ObjectKey) (*appsv1.DaemonSet, error)

func (Waiter) ForDaemonsetInNUMAResourcesOperatorStatus

func (wt Waiter) ForDaemonsetInNUMAResourcesOperatorStatus(ctx context.Context, nroObj *nropv1.NUMAResourcesOperator) (*nropv1.NUMAResourcesOperator, error)

func (Waiter) ForDaemonsetPodsCreation

func (wt Waiter) ForDaemonsetPodsCreation(ctx context.Context, ds *appsv1.DaemonSet, expectedPods int) (*appsv1.DaemonSet, error)

func (Waiter) ForDeploymentComplete

func (wt Waiter) ForDeploymentComplete(ctx context.Context, dp *appsv1.Deployment) (*appsv1.Deployment, error)

func (Waiter) ForDeploymentReplicasCreation

func (wt Waiter) ForDeploymentReplicasCreation(ctx context.Context, dp *appsv1.Deployment, expectedReplicas int32) (*appsv1.Deployment, error)

func (Waiter) ForKubeletConfigDeleted

func (wt Waiter) ForKubeletConfigDeleted(ctx context.Context, kc *machineconfigv1.KubeletConfig) error

func (Waiter) ForMachineConfigPoolCondition

func (wt Waiter) ForMachineConfigPoolCondition(ctx context.Context, mcp *machineconfigv1.MachineConfigPool, condType machineconfigv1.MachineConfigPoolConditionType) error

func (Waiter) ForMachineConfigPoolDeleted

func (wt Waiter) ForMachineConfigPoolDeleted(ctx context.Context, mcp *machineconfigv1.MachineConfigPool) error

func (Waiter) ForNUMAResourcesOperatorDeleted

func (wt Waiter) ForNUMAResourcesOperatorDeleted(ctx context.Context, nrop *nropv1.NUMAResourcesOperator) error

func (Waiter) ForNUMAResourcesSchedulerDeleted

func (wt Waiter) ForNUMAResourcesSchedulerDeleted(ctx context.Context, nrSched *nropv1.NUMAResourcesScheduler) error

func (Waiter) ForPodDeleted

func (wt Waiter) ForPodDeleted(ctx context.Context, podNamespace, podName string) error

func (Waiter) ForPodListAllRunning

func (wt Waiter) ForPodListAllRunning(ctx context.Context, pods []*corev1.Pod) ([]*corev1.Pod, []*corev1.Pod)

func (Waiter) ForPodPhase

func (wt Waiter) ForPodPhase(ctx context.Context, podNamespace, podName string, phase corev1.PodPhase) (*corev1.Pod, error)

func (Waiter) ForReplicasetComplete

func (wt Waiter) ForReplicasetComplete(ctx context.Context, rs *appsv1.ReplicaSet) (*appsv1.ReplicaSet, error)

func (*Waiter) Interval

func (wt *Waiter) Interval(iv time.Duration) *Waiter

func (*Waiter) Steps

func (wt *Waiter) Steps(st int) *Waiter

func (*Waiter) Timeout

func (wt *Waiter) Timeout(tt time.Duration) *Waiter

func (Waiter) WhileInPodPhase

func (wt Waiter) WhileInPodPhase(ctx context.Context, podNamespace, podName string, phase corev1.PodPhase) error