statefulset

Documentation

Index

• Variables
• func CheckStatefulSets(namespace []string, clientset kubernetes.Interface, ...) error
• type DefaultRetryer
  • func (r *DefaultRetryer) RetryOnConflict(backoff wait.Backoff, fn func() error) error
• type Retryer

Variables

var (
	ErrListingStatefulSet    = errors.New("error listing statefulsets in namespace")
	ErrNoStatefulSet         = errors.New("error no statefulset found inside namespace")
	ErrNoNamespace           = errors.New("error no namespace provided")
	ErrStatefulSetNotHealthy = errors.New("error statefulset not in healthy state")
	ErrNamespaceEmpty        = errors.New("error namespace list empty")
	ErrInvalidInterval       = errors.New("error interval or timeout is invalid")
	ErrStatefulSetFailed     = errors.New("error statefulset test validation failed")
)

Functions

func CheckStatefulSets

func CheckStatefulSets(namespace []string, clientset kubernetes.Interface, interval, timeout time.Duration) error

Types

type DefaultRetryer

type DefaultRetryer struct{}

func (*DefaultRetryer) RetryOnConflict

func (r *DefaultRetryer) RetryOnConflict(backoff wait.Backoff, fn func() error) error

type Retryer

type Retryer interface {
	RetryOnConflict(backoff wait.Backoff, fn func() error) error
}

TODO: Come up with better solution This is done so that unit test can work fine as retry.RetryOnConflict only works on real Kubernetes cluster we are using fake to build up mock client for UT