utils

Documentation

Index

• Constants
• func APIServerVersionInfo(t *testing.T, clientset *kubernetes.Clientset)
• func AssertAllNodesReady(t *testing.T, clientset *kubernetes.Clientset, desiredNodeCount int)
• func AssertAllPodsReady(t *testing.T, clientset *kubernetes.Clientset)
• func IsKubeconfigValid(kubeconfig []byte) error
• func IsNodeReady(clientset *kubernetes.Clientset, node *v1.Node) (bool, error)
• func IsPodReady(clientset *kubernetes.Clientset, pod *v1.Pod) (bool, error)
• func RunEKSSmokeTest(t *testing.T, resources []apitype.ResourceV3, kubeconfigs ...interface{})
• type KubeAccess
  • func KubeconfigToKubeAccess(kubeconfig []byte) (*KubeAccess, error)

Constants

const MaxRetries = 20

MaxRetries is the maximum number of retries that a resource will be attempted to be fetched from the Kubernetes API Server.

const RetryInterval = 15

RetryInterval is the number of seconds to sleep in between requests to the Kubernetes API Server.

Functions

func APIServerVersionInfo

func APIServerVersionInfo(t *testing.T, clientset *kubernetes.Clientset)

APIServerVersionInfo prints out the API Server versions.

func AssertAllNodesReady

func AssertAllNodesReady(t *testing.T, clientset *kubernetes.Clientset, desiredNodeCount int)

AssertAllNodesReady ensures that all Nodes are running & have a "Ready" status condition.

func AssertAllPodsReady

func AssertAllPodsReady(t *testing.T, clientset *kubernetes.Clientset)

AssertAllPodsReady ensures all Pods have a "Running" or "Succeeded" status phase, and a "Ready" status condition.

func IsKubeconfigValid

func IsKubeconfigValid(kubeconfig []byte) error

IsKubeconfigValid checks that the kubeconfig provided is valid and error-free.

func IsNodeReady

func IsNodeReady(clientset *kubernetes.Clientset, node *v1.Node) (bool, error)

IsNodeReady attempts to check if the Node status condition is ready.

func IsPodReady

func IsPodReady(clientset *kubernetes.Clientset, pod *v1.Pod) (bool, error)

IsPodReady attempts to check if the Pod's status & condition is ready.

func RunEKSSmokeTest

func RunEKSSmokeTest(t *testing.T, resources []apitype.ResourceV3, kubeconfigs ...interface{})

RunEKSSmokeTest instantiates the EKS Smoke Test.

Types

type KubeAccess

type KubeAccess struct {
	RESTConfig *restclient.Config
	Clientset  *kubernetes.Clientset
}

KubeAccess holds the Kubernetes client-go client bag of tools to work with the APIServer: the RESTConfig, and Clientset for the various API groups.

func KubeconfigToKubeAccess

func KubeconfigToKubeAccess(kubeconfig []byte) (*KubeAccess, error)

KubeconfigToKubeAccess creates a KubeAccess object from a serialized kubeconfig.