tests

Documentation

Index

• Variables
• func WatchChangesUntil(watch SspWatch, predicate func(updatedSsp *sspv1beta1.SSP) bool, ...) error
• type PortForwarder
  • func NewPortForwarder(config *rest.Config, client rest.Interface) PortForwarder
• 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 PortForwarder

type PortForwarder interface {
	Connect(pod *core.Pod, remotePort uint16) (net.Conn, error)
}

func NewPortForwarder

func NewPortForwarder(config *rest.Config, client rest.Interface) PortForwarder

type SspWatch

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

func StartWatch

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