k8sclient

Documentation

Index

• func ConnectToK8s() (*kubernetes.Clientset, error)
• func GetIngressAddress(clientSet *kubernetes.Clientset, ingressName string, namespace string) (string, error)
• func HasPodSucceeded(c *kubernetes.Clientset, podName, namespace string) wait.ConditionFunc
• func IsPersistentVolumeClaimBound(c *kubernetes.Clientset, podName, namespace string) wait.ConditionFunc
• func IsPodReady(c *kubernetes.Clientset, podName, namespace string) wait.ConditionFunc
• func IsPodRunning(c *kubernetes.Clientset, podName, namespace string) wait.ConditionFunc
• func WaitForPodsReady(k8sClient *kubernetes.Clientset, namespace string, instance string, ...) error

Functions

func ConnectToK8s

func ConnectToK8s() (*kubernetes.Clientset, error)

ConnectToK8s establishes a connection to the k8s and returns a *kubernetes.Clientset

func GetIngressAddress

func GetIngressAddress(clientSet *kubernetes.Clientset, ingressName string, namespace string) (string, error)

GetIngressAddress gets the hostname or ip address of the ingress with name.

func HasPodSucceeded

func HasPodSucceeded(c *kubernetes.Clientset, podName, namespace string) wait.ConditionFunc

func IsPersistentVolumeClaimBound

func IsPersistentVolumeClaimBound(c *kubernetes.Clientset, podName, namespace string) wait.ConditionFunc

IsPersistentVolumeClaimBound TODO: add description.

func IsPodReady

func IsPodReady(c *kubernetes.Clientset, podName, namespace string) wait.ConditionFunc

IsPodReady check if the pod in question is running state

func IsPodRunning

func IsPodRunning(c *kubernetes.Clientset, podName, namespace string) wait.ConditionFunc

IsPodRunning check if the pod in question is running state

func WaitForPodsReady

func WaitForPodsReady(k8sClient *kubernetes.Clientset, namespace string, instance string, timeout time.Duration) error

WaitForPodsReady wait for pods to be running with a timeout, return error