util

Feb 15, 2019

Changes in this version

type MinikubeRunner

+ MountArgs string

+ func (m *MinikubeRunner) RunDaemon2(command string) (*exec.Cmd, *bufio.Reader, *bufio.Reader)

Dec 22, 2018

Changes in this version

+ func Logf(str string, args ...interface{})

Dec 10, 2018

Changes in this version

+ func WaitForFailedCreatePodSandBoxEvent() error

+ func WaitForGvisorControllerDeleted() error

+ func WaitForGvisorControllerRunning(t *testing.T) error

+ func WaitForUntrustedNginxRunning() error

type MinikubeRunner

+ Runtime string

+ func (m *MinikubeRunner) ParseEnvCmdOutput(out string) map[string]string

+ func (m *MinikubeRunner) RunWithContext(ctx context.Context, command string) ([]byte, error)

+ func (m *MinikubeRunner) SetRuntime(runtime string)

Jan 26, 2018

Changes in this version

+ func WaitForIngressControllerRunning(t *testing.T) error

+ func WaitForIngressDefaultBackendRunning(t *testing.T) error

+ func WaitForNginxRunning(t *testing.T) error

Sep 18, 2017

Changes in this version

type MinikubeRunner

+ StartArgs string

+ func (m *MinikubeRunner) GetLogs() string

Sep 7, 2017

Changes in this version

+ 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 MinikubeRunner

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

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

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

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

+ type PodStore struct

+ Reflector *cache.Reflector

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

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

+ func (s *PodStore) Stop()

Apr 7, 2017

Changes in this version

type MinikubeRunner

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

Mar 2, 2017

Changes in this version

type MinikubeRunner

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

Feb 2, 2017

Changes in this version

+ type KubectlRunner struct

+ BinaryPath string

+ T *testing.T

+ func NewKubectlRunner(t *testing.T) *KubectlRunner

+ func (k *KubectlRunner) CreateRandomNamespace() string

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

+ func (k *KubectlRunner) GetPod(name, namespace string) *api.Pod

+ func (k *KubectlRunner) IsPodReady(p *api.Pod) bool

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

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

+ type MinikubeRunner struct

+ Args string

+ BinaryPath string

+ T *testing.T

+ func (m *MinikubeRunner) CheckStatus(desired string)

+ func (m *MinikubeRunner) EnsureRunning()

+ func (m *MinikubeRunner) GetStatus() string

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

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

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

+ func (m *MinikubeRunner) Start()