util

Documentation

Index

• func GetClient() (kubernetes.Interface, error)
• func IsRetryableAPIError(err error) bool
• func Retry(t *testing.T, callback func() error, d time.Duration, attempts int) (err error)
• func StartPods(c kubernetes.Interface, namespace string, pod v1.Pod, waitForRunning bool) error
• func WaitForBusyboxRunning(t *testing.T, namespace string) error
• func WaitForDNSRunning(t *testing.T) error
• func WaitForDashboardRunning(t *testing.T) error
• func WaitForPodsWithLabelRunning(c kubernetes.Interface, ns string, label labels.Selector) error
• func WaitForRCToStabilize(t *testing.T, c kubernetes.Interface, ns, name string, timeout time.Duration) error
• func WaitForService(t *testing.T, c kubernetes.Interface, namespace, name string, exist bool, ...) error
• func WaitForServiceEndpointsNum(t *testing.T, c kubernetes.Interface, namespace, serviceName string, ...) error
• type KubectlRunner
  • func NewKubectlRunner(t *testing.T) *KubectlRunner
  • func (k *KubectlRunner) CreateRandomNamespace() string
  • func (k *KubectlRunner) DeleteNamespace(namespace string) error
  • func (k *KubectlRunner) RunCommand(args []string) (stdout []byte, err error)
  • func (k *KubectlRunner) RunCommandParseOutput(args []string, outputObj interface{}) error
• type MinikubeRunner
  • func (m *MinikubeRunner) CheckStatus(desired string)
  • func (m *MinikubeRunner) CheckStatusNoFail(desired string) error
  • func (m *MinikubeRunner) CombinedOutput(cmd string) (string, error)
  • func (m *MinikubeRunner) Copy(f assets.CopyableFile) error
  • func (m *MinikubeRunner) EnsureRunning()
  • func (m *MinikubeRunner) GetStatus() string
  • func (m *MinikubeRunner) Remove(f assets.CopyableFile) error
  • func (m *MinikubeRunner) Run(cmd string) error
  • func (m *MinikubeRunner) RunCommand(command string, checkError bool) string
  • func (m *MinikubeRunner) RunDaemon(command string) *exec.Cmd
  • func (m *MinikubeRunner) SSH(command string) (string, error)
  • func (m *MinikubeRunner) SetEnvFromEnvCmdOutput(dockerEnvVars string) error
  • func (m *MinikubeRunner) Start()
• type PodStore
  • func NewPodStore(c kubernetes.Interface, namespace string, label labels.Selector, ...) *PodStore
  • func (s *PodStore) List() []*v1.Pod
  • func (s *PodStore) Stop()

Functions

func GetClient

func GetClient() (kubernetes.Interface, error)

func IsRetryableAPIError

func IsRetryableAPIError(err error) bool

func Retry

func Retry(t *testing.T, callback func() error, d time.Duration, attempts int) (err error)

func StartPods

func StartPods(c kubernetes.Interface, namespace string, pod v1.Pod, waitForRunning bool) error

func WaitForBusyboxRunning

func WaitForBusyboxRunning(t *testing.T, namespace string) error

func WaitForDNSRunning

func WaitForDNSRunning(t *testing.T) error

func WaitForDashboardRunning

func WaitForDashboardRunning(t *testing.T) error

func WaitForPodsWithLabelRunning

func WaitForPodsWithLabelRunning(c kubernetes.Interface, ns string, label labels.Selector) error

Wait up to 10 minutes for all matching pods to become Running and at least one matching pod exists.

func WaitForRCToStabilize

func WaitForRCToStabilize(t *testing.T, c kubernetes.Interface, ns, name string, timeout time.Duration) error

WaitForRCToStabilize waits till the RC has a matching generation/replica count between spec and status.

func WaitForService

func WaitForService(t *testing.T, c kubernetes.Interface, namespace, name string, exist bool, interval, timeout time.Duration) error

WaitForService waits until the service appears (exist == true), or disappears (exist == false)

func WaitForServiceEndpointsNum

func WaitForServiceEndpointsNum(t *testing.T, c kubernetes.Interface, namespace, serviceName string, expectNum int, interval, timeout time.Duration) error

WaitForServiceEndpointsNum waits until the amount of endpoints that implement service to expectNum.

Types

type KubectlRunner

type KubectlRunner struct {
	T          *testing.T
	BinaryPath string
}

func NewKubectlRunner

func NewKubectlRunner(t *testing.T) *KubectlRunner

func (*KubectlRunner) CreateRandomNamespace

func (k *KubectlRunner) CreateRandomNamespace() string

func (*KubectlRunner) DeleteNamespace

func (k *KubectlRunner) DeleteNamespace(namespace string) error

func (*KubectlRunner) RunCommand

func (k *KubectlRunner) RunCommand(args []string) (stdout []byte, err error)

func (*KubectlRunner) RunCommandParseOutput

func (k *KubectlRunner) RunCommandParseOutput(args []string, outputObj interface{}) error

type MinikubeRunner

type MinikubeRunner struct {
	T          *testing.T
	BinaryPath string
	Args       string
}

func (*MinikubeRunner) CheckStatus

func (m *MinikubeRunner) CheckStatus(desired string)

func (*MinikubeRunner) CheckStatusNoFail

func (m *MinikubeRunner) CheckStatusNoFail(desired string) error

func (*MinikubeRunner) CombinedOutput

func (m *MinikubeRunner) CombinedOutput(cmd string) (string, error)

func (*MinikubeRunner) Copy

func (m *MinikubeRunner) Copy(f assets.CopyableFile) error

func (*MinikubeRunner) EnsureRunning

func (m *MinikubeRunner) EnsureRunning()

func (*MinikubeRunner) GetStatus

func (m *MinikubeRunner) GetStatus() string

func (*MinikubeRunner) Remove

func (m *MinikubeRunner) Remove(f assets.CopyableFile) error

func (*MinikubeRunner) Run

func (m *MinikubeRunner) Run(cmd string) error

func (*MinikubeRunner) RunCommand

func (m *MinikubeRunner) RunCommand(command string, checkError bool) string

func (*MinikubeRunner) RunDaemon

func (m *MinikubeRunner) RunDaemon(command string) *exec.Cmd

func (*MinikubeRunner) SSH

func (m *MinikubeRunner) SSH(command string) (string, error)

func (*MinikubeRunner) SetEnvFromEnvCmdOutput

func (m *MinikubeRunner) SetEnvFromEnvCmdOutput(dockerEnvVars string) error

func (*MinikubeRunner) Start

func (m *MinikubeRunner) Start()

type PodStore

type PodStore struct {
	cache.Store

	Reflector *cache.Reflector
	// contains filtered or unexported fields
}

func NewPodStore

func NewPodStore(c kubernetes.Interface, namespace string, label labels.Selector, field fields.Selector) *PodStore

func (*PodStore) List

func (s *PodStore) List() []*v1.Pod

func (*PodStore) Stop

func (s *PodStore) Stop()