k8sclient

Documentation

Index

• func ConnectToK8s() (*kubernetes.Clientset, error)
• func ConnectToK8sDynamic() (dynamic.Interface, error)
• func GetAPIServerLogs(ctx context.Context, k8sClient kubernetes.Interface, namespace string) ([]string, error)
• func GetClusterVersion(k8sClient kubernetes.Interface) (string, error)
• func GetIngressAddress(clientSet kubernetes.Interface, ingressName string, namespace string) (string, error)
• func GetK8sClientConfig() (*rest.Config, error)
• func GetOperatorLogs(ctx context.Context, k8sClient kubernetes.Interface, namespace string) ([]string, error)
• func GetPodLogs(ctx context.Context, k8sClient kubernetes.Interface, namespace string, ...) ([]string, error)
• func HasPodSucceeded(c kubernetes.Interface, podName, namespace string) wait.ConditionFunc
• func IsPersistentVolumeClaimBound(c kubernetes.Interface, podName, namespace string) wait.ConditionFunc
• func IsPodReady(c kubernetes.Interface, podName, namespace string) wait.ConditionFunc
• func IsPodRunning(c kubernetes.Interface, podName, namespace string) wait.ConditionFunc
• func WaitForPodsReady(k8sClient kubernetes.Interface, 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 ConnectToK8sDynamic

func ConnectToK8sDynamic() (dynamic.Interface, error)

ConnectToK8sDynamic establishes a connection to the k8s and returns a dynamic.Interface

func GetAPIServerLogs

func GetAPIServerLogs(ctx context.Context, k8sClient kubernetes.Interface, namespace string) ([]string, error)

GetAPIServerLogs returns the latest logs from the API server deployment

func GetClusterVersion

func GetClusterVersion(k8sClient kubernetes.Interface) (string, error)

GetClusterVersion returns the current version of the Kubernetes cluster

func GetIngressAddress

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

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

func GetK8sClientConfig

func GetK8sClientConfig() (*rest.Config, error)

func GetOperatorLogs

func GetOperatorLogs(ctx context.Context, k8sClient kubernetes.Interface, namespace string) ([]string, error)

GetOperatorLogs returns the logs from the operator

func GetPodLogs

func GetPodLogs(ctx context.Context, k8sClient kubernetes.Interface, namespace string, selector string) ([]string, error)

GetPodLogs returns logs for pods specified by the label selector

func HasPodSucceeded

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

HasPodSucceeded custom method for checing if Pod is succeded (handles PodFailed state too)

func IsPersistentVolumeClaimBound

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

IsPersistentVolumeClaimBound TODO: add description.

func IsPodReady

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

IsPodReady check if the pod in question is running state

func IsPodRunning

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

IsPodRunning check if the pod in question is running state

func WaitForPodsReady

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

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