tool

Documentation

Index

• func GetClientConfig(envSettings *cli.EnvSettings) clientcmd.ClientConfig
• func GetDecodedKey(publicKey string) ([]byte, error)
• func GetEncodedKey(publicKeyFileName string) (string, error)
• func GetKeyRing(targetDir string, publicKeys []string) (string, error)
• func GetPublicKeyDigest(publicKey string) (string, error)
• type Helm
  • func NewHelm(envSettings *cli.EnvSettings, args map[string]interface{}, ...) (*Helm, error)
  • func (h Helm) Install(ctx context.Context, namespace, chart, release, valuesFile string) error
  • func (h Helm) Test(ctx context.Context, namespace, release string) error
  • func (h Helm) Uninstall(namespace, release string) error
  • func (h Helm) Upgrade(ctx context.Context, namespace, chart, release string) error
• type Kubectl
  • func NewKubectl(kubeConfig clientcmd.ClientConfig) (*Kubectl, error)
  • func (k Kubectl) DeleteNamespace(context context.Context, namespace string) error
  • func (k Kubectl) GetServerVersion() (*version.Info, error)
  • func (k Kubectl) WaitForWorkloadResources(context context.Context, namespace string, selector string) error
• type ProcessExecutor
  • func NewProcessExecutor(debug bool) ProcessExecutor
  • func (p ProcessExecutor) RunProcessAndCaptureOutput(executable string, execArgs ...interface{}) (string, error)
  • func (p ProcessExecutor) RunProcessInDirAndCaptureOutput(workingDirectory string, executable string, execArgs ...interface{}) (string, error)
• type ProcessExecutorer

Functions

func GetClientConfig

func GetClientConfig(envSettings *cli.EnvSettings) clientcmd.ClientConfig

func GetDecodedKey

func GetDecodedKey(publicKey string) ([]byte, error)

func GetEncodedKey

func GetEncodedKey(publicKeyFileName string) (string, error)

func GetKeyRing

func GetKeyRing(targetDir string, publicKeys []string) (string, error)

func GetPublicKeyDigest

func GetPublicKeyDigest(publicKey string) (string, error)

Types

type Helm

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

func NewHelm

func NewHelm(envSettings *cli.EnvSettings, args map[string]interface{}, timeout time.Duration) (*Helm, error)

func (Helm) Install

func (h Helm) Install(ctx context.Context, namespace, chart, release, valuesFile string) error

func (Helm) Test

func (h Helm) Test(ctx context.Context, namespace, release string) error

func (Helm) Uninstall

func (h Helm) Uninstall(namespace, release string) error

func (Helm) Upgrade

func (h Helm) Upgrade(ctx context.Context, namespace, chart, release string) error

type Kubectl

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

func NewKubectl

func NewKubectl(kubeConfig clientcmd.ClientConfig) (*Kubectl, error)

func (Kubectl) DeleteNamespace

func (k Kubectl) DeleteNamespace(context context.Context, namespace string) error

func (Kubectl) GetServerVersion

func (k Kubectl) GetServerVersion() (*version.Info, error)

func (Kubectl) WaitForWorkloadResources

func (k Kubectl) WaitForWorkloadResources(context context.Context, namespace string, selector string) error

WaitForWorkloadResources returns nil when all pods for requested workload resources are confirmed ready or an error if resources cannot be confirmed ready before the timeout is exceeded. Currently checks deployments, daemonSets, and statefulSets.

type ProcessExecutor

type ProcessExecutor struct {
	exec.ProcessExecutor
}

func NewProcessExecutor

func NewProcessExecutor(debug bool) ProcessExecutor

func (ProcessExecutor) RunProcessAndCaptureOutput

func (p ProcessExecutor) RunProcessAndCaptureOutput(executable string, execArgs ...interface{}) (string, error)

func (ProcessExecutor) RunProcessInDirAndCaptureOutput

func (p ProcessExecutor) RunProcessInDirAndCaptureOutput(
	workingDirectory string,
	executable string,
	execArgs ...interface{},
) (string, error)

RunProcessInDirAndCaptureOutput overrides exec.ProcessExecutor's and inject the command line and any streamed content to either Stdout or Stderr into the returned error, if any.

type ProcessExecutorer

type ProcessExecutorer interface {
	RunProcessAndCaptureOutput(executable string, execArgs ...interface{}) (string, error)
}