util

Documentation

Index

• func Logf(str string, args ...interface{})
• func Retry(t *testing.T, callback func() error, d time.Duration, attempts int) (err error)
• func Retry2(callback func() error, d time.Duration, attempts int) (err error)
• func RetryX(callback func() error, initInterv time.Duration, maxTime time.Duration) error
• func WaitForBusyboxRunning(t *testing.T, namespace string, miniProfile string) error
• type KubectlRunner
  • func NewKubectlRunner(t *testing.T, profile ...string) *KubectlRunner
  • func (k *KubectlRunner) CreateRandomNamespace() string
  • func (k *KubectlRunner) DeleteNamespace(namespace string) error
  • func (k *KubectlRunner) RunCommand(args []string, useKubeContext ...bool) (stdout []byte, err error)
  • func (k *KubectlRunner) RunCommandParseOutput(args []string, outputObj interface{}, useKubeContext ...bool) error
• type MinikubeRunner
  • func (m *MinikubeRunner) CheckStatus(desired string)
  • func (m *MinikubeRunner) CheckStatusNoFail(desired string) error
  • func (m *MinikubeRunner) EnsureRunning(opts ...string)
  • func (m *MinikubeRunner) GetLogs() string
  • func (m *MinikubeRunner) ParseEnvCmdOutput(out string) map[string]string
  • func (m *MinikubeRunner) Remove(f assets.CopyableFile) error
  • func (m *MinikubeRunner) RunCommand(cmdStr string, failError bool, waitForRun ...bool) (string, string)
  • func (m *MinikubeRunner) RunCommandRetriable(cmdStr string, waitForRun ...bool) (stdout string, stderr string, err error)
  • func (m *MinikubeRunner) RunDaemon(cmdStr string) (*exec.Cmd, *bufio.Reader)
  • func (m *MinikubeRunner) RunDaemon2(cmdStr string) (*exec.Cmd, *bufio.Reader, *bufio.Reader)
  • func (m *MinikubeRunner) RunWithContext(ctx context.Context, cmdStr string, wait ...bool) (string, string, error)
  • func (m *MinikubeRunner) SSH(cmdStr string) (string, error)
  • func (m *MinikubeRunner) Start(opts ...string) (stdout string, stderr string, err error)
  • func (m *MinikubeRunner) Status() (status string, stderr string, err error)
  • func (m *MinikubeRunner) TearDown(t *testing.T)

Functions

func Logf

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

Logf writes logs to stdout if -v is set.

func Retry

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

Retry tries the callback for a number of attempts, with a delay between attempts

func Retry2

func Retry2(callback func() error, d time.Duration, attempts int) (err error)

Retry2 tries the callback for a number of attempts, with a delay without *testing.T

func RetryX

func RetryX(callback func() error, initInterv time.Duration, maxTime time.Duration) error

RetryX is expontential backoff retry

func WaitForBusyboxRunning

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

WaitForBusyboxRunning waits until busybox pod to be running

Types

type KubectlRunner

type KubectlRunner struct {
	Profile    string // kube-context maps to a minikube profile
	T          *testing.T
	BinaryPath string
}

KubectlRunner runs a command using kubectl

func NewKubectlRunner

func NewKubectlRunner(t *testing.T, profile ...string) *KubectlRunner

NewKubectlRunner creates a new KubectlRunner

func (*KubectlRunner) CreateRandomNamespace

func (k *KubectlRunner) CreateRandomNamespace() string

CreateRandomNamespace creates a random namespace

func (*KubectlRunner) DeleteNamespace

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

DeleteNamespace deletes the namespace

func (*KubectlRunner) RunCommand

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

RunCommand runs a command, returning stdout

func (*KubectlRunner) RunCommandParseOutput

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

RunCommandParseOutput runs a command and parses the JSON output

type MinikubeRunner

type MinikubeRunner struct {
	Profile      string
	T            *testing.T
	BinaryPath   string
	GlobalArgs   string
	StartArgs    string
	MountArgs    string
	Runtime      string
	TimeOutStart time.Duration // time to wait for minikube start before killing it
}

MinikubeRunner runs a command

func (*MinikubeRunner) CheckStatus

func (m *MinikubeRunner) CheckStatus(desired string)

CheckStatus makes sure the service has the desired status, or cause fatal error

func (*MinikubeRunner) CheckStatusNoFail

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

CheckStatusNoFail makes sure the service has the desired status, returning error

func (*MinikubeRunner) EnsureRunning

func (m *MinikubeRunner) EnsureRunning(opts ...string)

EnsureRunning makes sure the container runtime is running

func (*MinikubeRunner) GetLogs

func (m *MinikubeRunner) GetLogs() string

GetLogs returns the logs of a service

func (*MinikubeRunner) ParseEnvCmdOutput

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

ParseEnvCmdOutput parses the output of `env` (assumes bash)

func (*MinikubeRunner) Remove

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

Remove removes a file

func (*MinikubeRunner) RunCommand

func (m *MinikubeRunner) RunCommand(cmdStr string, failError bool, waitForRun ...bool) (string, string)

RunCommand executes a command, optionally checking for error and by default waits for run to finish

func (*MinikubeRunner) RunCommandRetriable

func (m *MinikubeRunner) RunCommandRetriable(cmdStr string, waitForRun ...bool) (stdout string, stderr string, err error)

RunCommandRetriable Error executes a command, returns error the purpose of this command is to make it retriable and better logging for retrying

func (*MinikubeRunner) RunDaemon

func (m *MinikubeRunner) RunDaemon(cmdStr string) (*exec.Cmd, *bufio.Reader)

RunDaemon executes a command, returning the stdout

func (*MinikubeRunner) RunDaemon2

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

RunDaemon2 executes a command, returning the stdout and stderr

func (*MinikubeRunner) RunWithContext

func (m *MinikubeRunner) RunWithContext(ctx context.Context, cmdStr string, wait ...bool) (string, string, error)

RunWithContext calls the minikube command with a context, useful for timeouts.

func (*MinikubeRunner) SSH

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

SSH returns the output of running a command using SSH

func (*MinikubeRunner) Start

func (m *MinikubeRunner) Start(opts ...string) (stdout string, stderr string, err error)

Start starts the cluster

func (*MinikubeRunner) Status

func (m *MinikubeRunner) Status() (status string, stderr string, err error)

Status returns the status of a service

func (*MinikubeRunner) TearDown

func (m *MinikubeRunner) TearDown(t *testing.T)

TearDown deletes minikube without waiting for it. used to free up ram/cpu after each test