util

Documentation

Overview

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• Constants
• Variables
• func CreateKubeNamespace(baseName string, kubeClientSet kubernetes.Interface) (*v1.Namespace, error)
• func DeleteKubeNamespace(namespace string, kubeClientSet kubernetes.Interface) error
• func ExecCmd(client kubernetes.Interface, config *restclient.Config, ...) (string, error)
• func GetKubeSA(baseName string, kubeClientSet kubernetes.Interface, ns string) (*v1.ServiceAccount, error)
• func NewConfig() (*restclient.Config, *kubernetes.Clientset, crclient.Client)
• func UpdateKubeSA(baseName string, kubeClientSet kubernetes.Interface, ns string, ...) (*v1.ServiceAccount, error)
• func WaitForKubeNamespaceNotExist(namespace string, kubeClientSet kubernetes.Interface) error
• func WaitForPodsReady(kubeClientSet kubernetes.Interface, expectedReplicas int, namespace string, ...) error
• func WaitForPodsRunning(kubeClientSet kubernetes.Interface, expectedReplicas int, namespace string, ...) (*v1.PodList, error)
• func WaitForURL(url string) error

Constants

const (
	// How often to poll for conditions.
	Poll = 2 * time.Second
)

Variables

var Scheme = runtime.NewScheme()

Functions

func CreateKubeNamespace

func CreateKubeNamespace(baseName string, kubeClientSet kubernetes.Interface) (*v1.Namespace, error)

CreateKubeNamespace creates a new Kubernetes Namespace for a test.

func DeleteKubeNamespace

func DeleteKubeNamespace(namespace string, kubeClientSet kubernetes.Interface) error

DeleteKubeNamespace will delete a namespace resource.

func ExecCmd

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

ExecCmd exec command on specific pod and wait the command's output.

func GetKubeSA

func GetKubeSA(baseName string, kubeClientSet kubernetes.Interface, ns string) (*v1.ServiceAccount, error)

UpdateKubeSA updates a new Kubernetes Service Account for a test.

func NewConfig

func NewConfig() (*restclient.Config, *kubernetes.Clientset, crclient.Client)

NewConfig loads and returns the kubernetes credentials from the environment. KUBECONFIG env var takes precedence and falls back to in-cluster config.

func UpdateKubeSA

func UpdateKubeSA(baseName string, kubeClientSet kubernetes.Interface, ns string, annotations map[string]string) (*v1.ServiceAccount, error)

UpdateKubeSA updates a new Kubernetes Service Account for a test.

func WaitForKubeNamespaceNotExist

func WaitForKubeNamespaceNotExist(namespace string, kubeClientSet kubernetes.Interface) error

WaitForKubeNamespaceNotExist will wait for the namespace with the given name to not exist for up to 2 minutes.

func WaitForPodsReady

func WaitForPodsReady(kubeClientSet kubernetes.Interface, expectedReplicas int, namespace string, opts metav1.ListOptions) error

WaitForPodsReady waits for a given amount of time until a group of Pods is running in the given namespace.

func WaitForPodsRunning

func WaitForPodsRunning(kubeClientSet kubernetes.Interface, expectedReplicas int, namespace string, opts metav1.ListOptions) (*v1.PodList, error)

WaitForPodsRunning waits for a given amount of time until a group of Pods is running in the given namespace.

func WaitForURL

func WaitForURL(url string) error

WaitForURL tests the provided url. Once a http 200 is returned the func returns with no error. Timeout is 5min.