service

Documentation

Index

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

Variables

var (
	ErrNoNamespace       = errors.New("error no namespace provided")
	ErrListingService    = errors.New("error listing services in namespace")
	ErrNoService         = errors.New("error no service in namespace")
	ErrNamespaceEmpty    = errors.New("error namespace list empty")
	ErrServiceNotHealthy = errors.New("error service not in healthy state")
	ErrInvalidInterval   = errors.New("error interval or timeout is invalid")
	ErrServiceFailed     = errors.New("error service test validation failed")
)

Functions

func CheckServices

func CheckServices(namespaces []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