wait

Documentation

Index

• Constants
• func AreDaemonSetPodsReady(newStatus *appsv1.DaemonSetStatus) bool
• func SetBaseValues(interval, timeout time.Duration)
• 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, log logr.Logger) *Waiter
  • func (wt Waiter) ForDaemonSetDeleted(ctx context.Context, namespace, name string) error
  • 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) ForDeploymentComplete(ctx context.Context, dp *appsv1.Deployment) (*appsv1.Deployment, error)
  • func (wt Waiter) ForDeploymentCompleteByKey(ctx context.Context, key ObjectKey, replicas int32) (*appsv1.Deployment, error)
  • func (wt Waiter) ForDeploymentDeleted(ctx context.Context, namespace, name string) error
  • func (wt Waiter) ForNamespaceDeleted(ctx context.Context, namespace string) error
  • func (wt *Waiter) Interval(iv time.Duration) *Waiter
  • func (wt *Waiter) String() string
  • func (wt *Waiter) Timeout(tt time.Duration) *Waiter

Constants

const (
	// found by trial and error, no hard math behind, can change anytime
	DefaultPollInterval = 2 * time.Second
	DefaultPollTimeout  = 2 * time.Minute
)

Functions

func AreDaemonSetPodsReady

func AreDaemonSetPodsReady(newStatus *appsv1.DaemonSetStatus) bool

func SetBaseValues

func SetBaseValues(interval, timeout time.Duration)

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
	Log          logr.Logger
	PollTimeout  time.Duration
	PollInterval time.Duration
}

func With

func With(cli client.Client, log logr.Logger) *Waiter

func (Waiter) ForDaemonSetDeleted

func (wt Waiter) ForDaemonSetDeleted(ctx context.Context, namespace, name string) error

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) ForDeploymentComplete

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

func (Waiter) ForDeploymentCompleteByKey

func (wt Waiter) ForDeploymentCompleteByKey(ctx context.Context, key ObjectKey, replicas int32) (*appsv1.Deployment, error)

func (Waiter) ForDeploymentDeleted

func (wt Waiter) ForDeploymentDeleted(ctx context.Context, namespace, name string) error

func (Waiter) ForNamespaceDeleted

func (wt Waiter) ForNamespaceDeleted(ctx context.Context, namespace string) error

func (*Waiter) Interval

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

func (*Waiter) String

func (wt *Waiter) String() string

func (*Waiter) Timeout

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