runner

package

v0.10.0 Latest Latest Go to latest Published: Oct 9, 2019 License: Apache-2.0 Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

func IsRunning(stdout string) bool

IsRunning checks if the given output represents the "Running" status of a Kubernetes pod.

func MakeShellCommand(cmd string, variables TemplateVariables) (string, error)

MakeShellCommand render text template with given `variables` render-context

type Runner struct {
	Conn    ssh.Connection
	Prefix  string
	OS      string
	Verbose bool
}

Runner bundles a connection to a host with the verbosity and other options for running commands via SSH.

func (r *Runner) Run(cmd string, variables TemplateVariables) (string, string, error)

Run executes a given command/script, optionally printing its output to stdout/stderr.

func (r *Runner) WaitForCondition(cmd string, timeout time.Duration, validator validatorFunc) bool

WaitForCondition waits for something to be true.

func (r *Runner) WaitForPod(namespace string, name string, timeout time.Duration) error

WaitForPod waits for the availability of the given Kubernetes element.

type Tee struct {
	// contains filtered or unexported fields
}

Tee mimics the unix `tee` command by piping its input through to the upstream writer and also capturing it in a buffer.

func NewTee(wc io.WriteCloser) *Tee

NewTee constructor

func (t *Tee) Close() error

Close underlying io.Closer

func (t *Tee) String() string

func (t *Tee) Write(p []byte) (int, error)

type TemplateVariables map[string]interface{}

TemplateVariables is a render context for templates