util

Documentation

Index

• func ArePodsUp(clientset *kubernetes.Clientset, namespace string, t *testing.T, ...)
• func CreateNamespace(client *kubernetes.Clientset, clusterID string, name string) (*v1.Namespace, error)
• func CreateNodePort(client *kubernetes.Clientset, clusterID, appName, name, namespace string) (*v1.Service, error)
• func DeleteNamespace(client *kubernetes.Clientset, name string) error
• func ExecCmd(config *rest.Config, client *kubernetes.Clientset, ...) (string, string, error)
• func GetNodes(client *kubernetes.Clientset, clusterID string, labelSelector string) (*v1.NodeList, error)
• func PodWatcher(location string, client *kubernetes.Clientset, ...)
• func WaitForPodToBeReady(location string, client *kubernetes.Clientset, waitSeconds time.Duration, ...) bool
• type Tester
  • func GetTester() *Tester

Functions

func ArePodsUp

func ArePodsUp(clientset *kubernetes.Clientset, namespace string, t *testing.T, clustername string)

func CreateNamespace

func CreateNamespace(client *kubernetes.Clientset, clusterID string, name string) (*v1.Namespace, error)

func CreateNodePort

func CreateNodePort(client *kubernetes.Clientset, clusterID, appName, name, namespace string) (*v1.Service, error)

func DeleteNamespace

func DeleteNamespace(client *kubernetes.Clientset, name string) error

func ExecCmd

func ExecCmd(config *rest.Config, client *kubernetes.Clientset, podName, namespace, command string) (string, string, error)

func GetNodes

func GetNodes(client *kubernetes.Clientset, clusterID string, labelSelector string) (*v1.NodeList, error)

func PodWatcher

func PodWatcher(location string, client *kubernetes.Clientset, clusterID, namespace, podName string, podReady, stopCh chan bool)

func WaitForPodToBeReady

func WaitForPodToBeReady(location string, client *kubernetes.Clientset, waitSeconds time.Duration, clusterID, namespace, podName string) bool

Types

type Tester

type Tester struct {
	Config1    *rest.Config
	Config2    *rest.Config
	Client1    *kubernetes.Clientset
	Client2    *kubernetes.Clientset
	ClusterID1 string
	ClusterID2 string
	Namespace  string
}

func GetTester

func GetTester() *Tester