tests

Documentation

Index

• Variables
• func WatchChangesUntil(watch SspWatch, predicate func(updatedSsp *sspv1beta1.SSP) bool, ...) error
• type SspWatch
  • func StartWatch(listerWatcher cache.ListerWatcher) (SspWatch, error)

Variables

var ErrorTimeout = fmt.Errorf("timed out")

Functions

func WatchChangesUntil

func WatchChangesUntil(watch SspWatch, predicate func(updatedSsp *sspv1beta1.SSP) bool, timeout time.Duration) error

Types

type SspWatch

type SspWatch interface {
	Stop()
	Updates() <-chan *sspv1beta1.SSP
	Error() error
}

func StartWatch

func StartWatch(listerWatcher cache.ListerWatcher) (SspWatch, error)