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) ForCRDCreated(ctx context.Context, name string) (*apiextensionv1.CustomResourceDefinition, error)
  • func (wt Waiter) ForCRDDeleted(ctx context.Context, name string) error
  • 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) ForCRDCreated

func (wt Waiter) ForCRDCreated(ctx context.Context, name string) (*apiextensionv1.CustomResourceDefinition, error)

func (Waiter) ForCRDDeleted

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

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