conditions

Documentation

Index

• type Awaiter
  • func NewConditionAwaiter[T RuntimeObjectWithStatusConditions, L any, PL ObjectList[L]](timeout time.Duration) *Awaiter[T, L, PL]
  • func (a *Awaiter[T, L, PL]) AwaitCondition(ctx context.Context, k8sClient client.WithWatch, object client.Object, ...) (T, error)
  • func (a *Awaiter[T, L, PL]) AwaitState(ctx context.Context, k8sClient client.WithWatch, object client.Object, ...) (T, error)
• type ObjectList
• type RuntimeObjectWithStatusConditions

Types

type Awaiter

type Awaiter[T RuntimeObjectWithStatusConditions, L any, PL ObjectList[L]] struct {
	// contains filtered or unexported fields
}

func NewConditionAwaiter

func NewConditionAwaiter[T RuntimeObjectWithStatusConditions, L any, PL ObjectList[L]](timeout time.Duration) *Awaiter[T, L, PL]

func (*Awaiter[T, L, PL]) AwaitCondition

func (a *Awaiter[T, L, PL]) AwaitCondition(ctx context.Context, k8sClient client.WithWatch, object client.Object, conditionType string) (T, error)

func (*Awaiter[T, L, PL]) AwaitState

func (a *Awaiter[T, L, PL]) AwaitState(ctx context.Context, k8sClient client.WithWatch, object client.Object, checkState func(T) error) (T, error)

type ObjectList

type ObjectList[L any] interface {
	*L
	client.ObjectList
}

type RuntimeObjectWithStatusConditions

type RuntimeObjectWithStatusConditions interface {
	client.Object
	StatusConditions() []metav1.Condition
}