framework

package
v0.0.0-...-0677d28 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 12, 2020 License: Apache-2.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// Poll how often to poll for conditions
	Poll = 2 * time.Second

	// DefaultTimeout time to wait for operations to complete
	DefaultTimeout = 5 * time.Minute
)

Variables

View Source 
var (
	// KubectlPath defines the full path of the kubectl binary
	KubectlPath = "/usr/local/bin/kubectl"
)
View Source 
var RunID = uuid.NewUUID()

RunID unique identifier of the e2e run

Functions

func CreateIngressMASecret 

func CreateIngressMASecret(client kubernetes.Interface, host string, secretName, namespace string) (*tls.Config, error)

CreateIngressMASecret creates or updates a Secret containing a Mutual Auth certificate-chain for the given Ingress and returns a TLS configuration suitable for HTTP clients to use against that particular Ingress.

func CreateIngressTLSSecret 

func CreateIngressTLSSecret(client kubernetes.Interface, hosts []string, secretName, namespace string) (*tls.Config, error)

CreateIngressTLSSecret creates or updates a Secret containing a TLS certificate for the given Ingress and returns a TLS configuration suitable for HTTP clients to use against that particular Ingress.

func CreateKubeNamespace 

func CreateKubeNamespace(baseName string, c kubernetes.Interface) (string, error)

CreateKubeNamespace creates a new namespace in the cluster

func DeleteKubeNamespace 

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

DeleteKubeNamespace deletes a namespace and all the objects inside

func ExpectNoError 

func ExpectNoError(err error, explain ...interface{})

ExpectNoError tests whether an error occurred.

func Failf 

func Failf(format string, args ...interface{})

Failf logs to the INFO logs and fails the test.

func IngressNginxDescribe 

func IngressNginxDescribe(text string, body func()) bool

IngressNginxDescribe wrapper function for ginkgo describe. Adds namespacing.

func LoadConfig 

func LoadConfig(config, context string) (*rest.Config, error)

LoadConfig deserializes the contents of a kubeconfig file into a REST configuration.

func Logf 

func Logf(format string, args ...interface{})

Logf logs to the INFO logs.

func Logs 

func Logs(pod *v1.Pod) (string, error)

Logs returns the log entries of a given Pod.

func NewInt32 

func NewInt32(val int32) *int32

NewInt32 converts int32 to a pointer

func NewInt64 

func NewInt64(val int64) *int64

NewInt64 converts int64 to a pointer

func NewSingleCatchAllIngress 

func NewSingleCatchAllIngress(name, ns, service string, port int, annotations *map[string]string) *extensions.Ingress

NewSingleCatchAllIngress creates a simple ingress with a catch-all backend

func NewSingleIngress 

func NewSingleIngress(name, path, host, ns, service string, port int, annotations *map[string]string) *extensions.Ingress

NewSingleIngress creates a simple ingress rule

func NewSingleIngressWithBackendAndRules 

func NewSingleIngressWithBackendAndRules(name, path, host, ns, defaultService string, defaultPort int, service string, port int, annotations *map[string]string) *extensions.Ingress

NewSingleIngressWithBackendAndRules creates an ingress with both a default backend and a rule

func NewSingleIngressWithTLS 

func NewSingleIngressWithTLS(name, path, host string, tlsHosts []string, ns, service string, port int, annotations *map[string]string) *extensions.Ingress

NewSingleIngressWithTLS creates a simple ingress rule with TLS spec included

func RegisterCommonFlags 

func RegisterCommonFlags()

RegisterCommonFlags registers flags common to all e2e test suites.

func RegisterParseFlags 

func RegisterParseFlags()

RegisterParseFlags registers and parses flags for the test binary.

func RemoveCleanupAction 

func RemoveCleanupAction(p CleanupActionHandle)

RemoveCleanupAction removes a function that was installed by AddCleanupAction.

func RestclientConfig 

func RestclientConfig(config, context string) (*api.Config, error)

RestclientConfig deserializes the contents of a kubeconfig file into a Config object.

func RunCleanupActions 

func RunCleanupActions()

RunCleanupActions runs all functions installed by AddCleanupAction. It does not remove them (see RemoveCleanupAction) but it does run unlocked, so they may remove themselves.

func Skipf 

func Skipf(format string, args ...interface{})

Skipf logs to the INFO logs and skips the test.

func UpdateDeployment 

func UpdateDeployment(kubeClientSet kubernetes.Interface, namespace string, name string, replicas int, updateFunc func(d *appsv1beta1.Deployment) error) error

UpdateDeployment runs the given updateFunc on the deployment and waits for it to be updated

func UpdateIngress 

func UpdateIngress(kubeClientSet kubernetes.Interface, namespace string, name string, updateFunc func(d *extensions.Ingress) error) error

UpdateIngress runs the given updateFunc on the ingress

func WaitForEndpoints 

func WaitForEndpoints(kubeClientSet kubernetes.Interface, timeout time.Duration, name, ns string, expectedEndpoints int) error

WaitForEndpoints waits for a given amount of time until an endpoint contains.

func WaitForFileInFS 

func WaitForFileInFS(file string, fs file.Filesystem) error

WaitForFileInFS waits a default amount of time for the specified file is present in the filesystem

func WaitForIngressInNamespace 

func WaitForIngressInNamespace(c kubernetes.Interface, namespace, name string) error

WaitForIngressInNamespace waits until a particular ingress object exists namespace

func WaitForKubeNamespaceNotExist 

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

WaitForKubeNamespaceNotExist waits until a namespaces is not present in the cluster

func WaitForNoIngressInNamespace 

func WaitForNoIngressInNamespace(c kubernetes.Interface, namespace, name string) error

WaitForNoIngressInNamespace waits until there is no ingress object in a particular namespace

func WaitForNoPodsInNamespace 

func WaitForNoPodsInNamespace(c kubernetes.Interface, namespace string) error

WaitForNoPodsInNamespace waits until there are no pods running in a namespace

func WaitForPodRunningInNamespace 

func WaitForPodRunningInNamespace(c kubernetes.Interface, pod *v1.Pod) error

WaitForPodRunningInNamespace waits a default amount of time (PodStartTimeout) for the specified pod to become running. Returns an error if timeout occurs first, or pod goes in to failed state.

func WaitForPodsReady 

func WaitForPodsReady(kubeClientSet kubernetes.Interface, timeout time.Duration, 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 WaitForSecretInNamespace 

func WaitForSecretInNamespace(c kubernetes.Interface, namespace, name string) error

WaitForSecretInNamespace waits a default amount of time for the specified secret is present in a particular namespace

func WaitForTLS 

func WaitForTLS(url string, tlsConfig *tls.Config)

WaitForTLS waits until the TLS handshake with a given server completes successfully.

Types

type CleanupActionHandle 

type CleanupActionHandle *int

CleanupActionHandle is a handle used to perform a cleanup action.

func AddCleanupAction 

func AddCleanupAction(fn func()) CleanupActionHandle

AddCleanupAction installs a function that will be called in the event of the whole test being terminated. This allows arbitrary pieces of the overall test to hook into SynchronizedAfterSuite().

type Framework 

type Framework struct {
	BaseName string

	// A Kubernetes and Service Catalog client
	KubeClientSet          kubernetes.Interface
	KubeConfig             *restclient.Config
	APIExtensionsClientSet apiextcs.Interface

	IngressController *ingressController
	// contains filtered or unexported fields
}

Framework supports common operations used by e2e tests; it will keep a client & a namespace for you.

func NewDefaultFramework 

func NewDefaultFramework(baseName string) *Framework

NewDefaultFramework makes a new framework and sets up a BeforeEach/AfterEach for you (you can write additional before/after each functions).

func (*Framework) AfterEach 

func (f *Framework) AfterEach()

AfterEach deletes the namespace, after reading its events.

func (*Framework) BeforeEach 

func (f *Framework) BeforeEach()

BeforeEach gets a client and makes a namespace.

func (*Framework) DeleteNGINXPod 

func (f *Framework) DeleteNGINXPod(grace int64)

DeleteNGINXPod deletes the currently running pod. It waits for the replacement pod to be up. Grace period to wait for pod shutdown is in seconds.

func (*Framework) EnsureConfigMap 

func (f *Framework) EnsureConfigMap(configMap *api.ConfigMap) (*api.ConfigMap, error)

EnsureConfigMap creates a ConfigMap object or returns it if it already exists.

func (*Framework) EnsureDeployment 

func (f *Framework) EnsureDeployment(deployment *extensions.Deployment) (*extensions.Deployment, error)

EnsureDeployment creates a Deployment object or returns it if it already exists.

func (*Framework) EnsureIngress 

func (f *Framework) EnsureIngress(ingress *extensions.Ingress) *extensions.Ingress

EnsureIngress creates an Ingress object or returns it if it already exists.

func (*Framework) EnsureSecret 

func (f *Framework) EnsureSecret(secret *api.Secret) *api.Secret

EnsureSecret creates a Secret object or returns it if it already exists.

func (*Framework) EnsureService 

func (f *Framework) EnsureService(service *core.Service) *core.Service

EnsureService creates a Service object or returns it if it already exists.

func (*Framework) ExecCommand 

func (f *Framework) ExecCommand(pod *v1.Pod, command string) (string, error)

ExecCommand executes a command inside a the first container in a running pod

func (*Framework) ExecIngressPod 

func (f *Framework) ExecIngressPod(command string) (string, error)

ExecIngressPod executes a command inside the first container in ingress controller running pod

func (*Framework) GetNginxConfigMapData 

func (f *Framework) GetNginxConfigMapData() (map[string]string, error)

GetNginxConfigMapData gets ingress-nginx's nginx-configuration map's data

func (*Framework) GetNginxIP 

func (f *Framework) GetNginxIP() string

GetNginxIP returns the IP address of the minikube cluster where the NGINX ingress controller is running

func (*Framework) GetNginxPort 

func (f *Framework) GetNginxPort(name string) (int, error)

GetNginxPort returns the number of TCP port where NGINX is running

func (*Framework) GetNginxURL 

func (f *Framework) GetNginxURL(scheme RequestScheme) string

GetNginxURL returns the URL should be used to make a request to NGINX

func (*Framework) KubectlProxy 

func (f *Framework) KubectlProxy(port int) (int, *exec.Cmd, error)

KubectlProxy creates a proxy to kubernetes apiserver

func (*Framework) NewDeployment 

func (f *Framework) NewDeployment(name, image string, port int32, replicas int32)

NewDeployment creates a new deployment in a particular namespace.

func (*Framework) NewEchoDeployment 

func (f *Framework) NewEchoDeployment()

NewEchoDeployment creates a new single replica deployment of the echoserver image in a particular namespace

func (*Framework) NewEchoDeploymentWithNameAndReplicas 

func (f *Framework) NewEchoDeploymentWithNameAndReplicas(name string, replicas int32)

NewEchoDeploymentWithNameAndReplicas creates a new deployment of the echoserver image in a particular namespace. Number of replicas is configurable and name is configurable

func (*Framework) NewEchoDeploymentWithReplicas 

func (f *Framework) NewEchoDeploymentWithReplicas(replicas int32)

NewEchoDeploymentWithReplicas creates a new deployment of the echoserver image in a particular namespace. Number of replicas is configurable

func (*Framework) NewGRPCFortuneTellerDeployment 

func (f *Framework) NewGRPCFortuneTellerDeployment()

NewGRPCFortuneTellerDeployment creates a new single replica deployment of the fortune teller image in a particular namespace

func (*Framework) NewHttpbinDeployment 

func (f *Framework) NewHttpbinDeployment()

NewHttpbinDeployment creates a new single replica deployment of the httpbin image in a particular namespace.

func (*Framework) NewInfluxDBDeployment 

func (f *Framework) NewInfluxDBDeployment()

NewInfluxDBDeployment creates an InfluxDB server configured to reply on 8086/tcp and 8089/udp

func (*Framework) NewIngressController 

func (f *Framework) NewIngressController(namespace string) error

NewIngressController deploys a new NGINX Ingress controller in a namespace

func (*Framework) NewNewGRPCFortuneTellerDeploymentWithReplicas 

func (f *Framework) NewNewGRPCFortuneTellerDeploymentWithReplicas(replicas int32)

NewNewGRPCFortuneTellerDeploymentWithReplicas creates a new deployment of the fortune teller image in a particular namespace. Number of replicas is configurable

func (*Framework) NewSlowEchoDeployment 

func (f *Framework) NewSlowEchoDeployment()

NewSlowEchoDeployment creates a new deployment of the slow echo server image in a particular namespace.

func (*Framework) NginxLogs 

func (f *Framework) NginxLogs() (string, error)

NginxLogs returns the logs of the nginx ingress controller pod running

func (*Framework) SetNginxConfigMapData 

func (f *Framework) SetNginxConfigMapData(cmData map[string]string)

SetNginxConfigMapData sets ingress-nginx's nginx-configuration configMap data

func (*Framework) UpdateNginxConfigMapData 

func (f *Framework) UpdateNginxConfigMapData(key string, value string)

UpdateNginxConfigMapData updates single field in ingress-nginx's nginx-configuration map data

func (*Framework) WaitForNginxConfiguration 

func (f *Framework) WaitForNginxConfiguration(matcher func(cfg string) bool)

WaitForNginxConfiguration waits until the nginx configuration contains a particular configuration

func (*Framework) WaitForNginxServer 

func (f *Framework) WaitForNginxServer(name string, matcher func(cfg string) bool)

WaitForNginxServer waits until the nginx configuration contains a particular server section

type RequestScheme 

type RequestScheme string

RequestScheme define a scheme used in a test request. 

const (
	HTTP  RequestScheme = "http"
	HTTPS RequestScheme = "https"
)

These are valid test request schemes.

type TestContextType 

type TestContextType struct {
	KubeHost    string
	KubeConfig  string
	KubeContext string
}

TestContextType describes the client context to use in communications with the Kubernetes API. 

var TestContext TestContextType

TestContext is the global client context for tests.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.