util

Documentation

Index

• Constants
• func CheckErr(err error)
• func CreateClientAndWaitForAPI(file string) (*clientset.Clientset, error)
• func KubernetesReleaseVersion(version string) (string, error)
• func ParseTemplate(strtmpl string, obj interface{}) ([]byte, error)
• func WaitForAPI(client *clientset.Clientset)
• func WaitForPodsWithLabel(client *clientset.Clientset, labelKeyValPair string)

Constants

const (
	DefaultErrorExitCode = 1
	PreFlightExitCode    = 2
	ValidationExitCode   = 3
)

Functions

func CheckErr

func CheckErr(err error)

CheckErr prints a user friendly error to STDERR and exits with a non-zero exit code. Unrecognized errors will be printed with an "error: " prefix.

This method is generic to the command in use and may be used by non-Kubectl commands.

func CreateClientAndWaitForAPI

func CreateClientAndWaitForAPI(file string) (*clientset.Clientset, error)

CreateClientAndWaitForAPI takes a path to a kubeconfig file, makes a client of it and waits for the API to be healthy

func KubernetesReleaseVersion

func KubernetesReleaseVersion(version string) (string, error)

KubernetesReleaseVersion is helper function that can fetch available version information from release servers based on label names, like "stable" or "latest".

If argument is already semantic version string, it will return same string.

In case of labels, it tries to fetch from release servers and then return actual semantic version.

Available names on release servers:

stable      (latest stable release)
stable-1    (latest stable release in 1.x)
stable-1.0  (and similarly 1.1, 1.2, 1.3, ...)
latest      (latest release, including alpha/beta)
latest-1    (latest release in 1.x, including alpha/beta)
latest-1.0  (and similarly 1.1, 1.2, 1.3, ...)

func ParseTemplate

func ParseTemplate(strtmpl string, obj interface{}) ([]byte, error)

func WaitForAPI

func WaitForAPI(client *clientset.Clientset)

WaitForAPI waits for the API Server's /healthz endpoint to report "ok"

func WaitForPodsWithLabel

func WaitForPodsWithLabel(client *clientset.Clientset, labelKeyValPair string)

WaitForPodsWithLabel will lookup pods with the given label and wait until they are all reporting status as running.