kube

Documentation

Overview

Package e2e contains tests that validate the behavior of gmp-operator against a cluster. To make tests simple and fast, the test suite runs the operator internally. The CRDs are expected to be installed out of band (along with the operator deployment itself in a real world setup).

Index

• func Debug(ctx context.Context, clientSet kubernetes.Interface, kubeClient client.Client, ...) error
• func DeploymentComplete(deployment *appsv1.Deployment, newStatus *appsv1.DeploymentStatus) bool
• func DeploymentContainer(deployment *appsv1.Deployment, name string) (*corev1.Container, error)
• func DeploymentPods(ctx context.Context, kubeClient client.Client, namespace, name string) ([]corev1.Pod, error)
• func Events(ctx context.Context, kubeClient client.Client, gvk schema.GroupVersionKind, ...) ([]string, error)
• func PodLogs(ctx context.Context, clientSet kubernetes.Interface, ...) (string, error)
• func PortForwardClient(restConfig *rest.Config, kubeClient client.Client, out, errOut io.Writer) (*http.Client, error)
• func ResourceFromYAML(scheme *runtime.Scheme, b []byte) (client.Object, error)
• func ResourcesFromYAML(scheme *runtime.Scheme, b []byte) ([]client.Object, error)
• func WaitForDeploymentReady(ctx context.Context, kubeClient client.Client, namespace, name string) error

Functions

func Debug

func Debug(ctx context.Context, clientSet kubernetes.Interface, kubeClient client.Client, o client.Object, out io.Writer) error

Debug prints both events and logs of the given resource. Consider passing a new context here in case the original context is cancelled.

func DeploymentComplete

func DeploymentComplete(deployment *appsv1.Deployment, newStatus *appsv1.DeploymentStatus) bool

Copied from https://github.com/kubernetes/kubernetes/blob/master/pkg/controller/deployment/util/deployment_util.go DeploymentComplete considers a deployment to be complete once all of its desired replicas are updated and available, and no old pods are running.

func DeploymentContainer

func DeploymentContainer(deployment *appsv1.Deployment, name string) (*corev1.Container, error)

func DeploymentPods

func DeploymentPods(ctx context.Context, kubeClient client.Client, namespace, name string) ([]corev1.Pod, error)

DeploymentPods returns the pods used for the given Deployment.

func Events

func Events(ctx context.Context, kubeClient client.Client, gvk schema.GroupVersionKind, namespace, name string) ([]string, error)

Events returns the events of the given resource.

func PodLogs

func PodLogs(ctx context.Context, clientSet kubernetes.Interface, namespace, name, container string) (string, error)

PodLogs returns the logs of the pod with the given name.

func PortForwardClient

func PortForwardClient(restConfig *rest.Config, kubeClient client.Client, out, errOut io.Writer) (*http.Client, error)

PortForwardClient returns a client that ports-forward all Kubernetes-local HTTP requests to the host.

func ResourceFromYAML

func ResourceFromYAML(scheme *runtime.Scheme, b []byte) (client.Object, error)

func ResourcesFromYAML

func ResourcesFromYAML(scheme *runtime.Scheme, b []byte) ([]client.Object, error)

func WaitForDeploymentReady

func WaitForDeploymentReady(ctx context.Context, kubeClient client.Client, namespace, name string) error