e2e

Documentation

Index

• func AllInOneSmokeTest(jaegerInstanceName string)
• func CreateEsPortForward(esNamespace string) (portForwES *portforward.PortForwarder, closeChanES chan struct{}, ...)
• func CreatePortForward(namespace, podNamePrefix, containsImage string, ports []string, ...) (*portforward.PortForwarder, chan struct{})
• func DeleteEsIndices(esNamespace string)
• func ExecuteEsRequest(esNamespace, httpMethod, api string) ([]byte, error)
• func GetJaegerSelfProvSimpleProdCR(instanceName, namespace string, nodeCount int32) *v1.Jaeger
• func GetJaegerSimpleProdWithServerUrlsCR(name, esServerUrls string) *v1.Jaeger
• func GetPod(namespace, namePrefix, containsImage string, kubeclient kubernetes.Interface) corev1.Pod
• func ProductionSmokeTest(resourceName string)
• func ProductionSmokeTestWithNamespace(resourceName, smokeTestNamespace string)
• func WaitAndPollForHTTPResponse(targetURL string, condition ValidateHTTPResponseFunc) (err error)
• func WaitForCronJob(t *testing.T, kubeclient kubernetes.Interface, namespace, name string, ...) error
• func WaitForDaemonSet(t *testing.T, kubeclient kubernetes.Interface, namespace, name string, ...) error
• func WaitForDeployment(t *testing.T, kubeclient kubernetes.Interface, namespace, name string, ...) error
• func WaitForHTTPResponse(httpClient http.Client, method, url string, response interface{}) (err error)
• func WaitForIngress(t *testing.T, kubeclient kubernetes.Interface, namespace, name string, ...) (*networkingv1.Ingress, error)
• func WaitForJob(t *testing.T, kubeclient kubernetes.Interface, namespace, name string, ...) error
• func WaitForJobOfAnOwner(t *testing.T, kubeclient kubernetes.Interface, namespace, ownerName string, ...) error
• func WaitForSecret(secretName, secretNamespace string)
• func WaitForStatefulset(t *testing.T, kubeclient kubernetes.Interface, namespace, name string, ...) error
• type EsIndex
  • func GetEsIndices(esNamespace string) ([]EsIndex, error)
• type ValidateHTTPResponseFunc

Functions

func AllInOneSmokeTest

func AllInOneSmokeTest(jaegerInstanceName string)

AllInOneSmokeTest is for the all-in-one image, where query and collector use the same pod

func CreateEsPortForward

func CreateEsPortForward(esNamespace string) (portForwES *portforward.PortForwarder, closeChanES chan struct{}, esPort string)

CreateEsPortForward creates local port forwarding

func CreatePortForward

func CreatePortForward(namespace, podNamePrefix, containsImage string, ports []string, kConfig *rest.Config) (*portforward.PortForwarder, chan struct{})

CreatePortForward listens for local connections and forwards them to a remote pod

func DeleteEsIndices

func DeleteEsIndices(esNamespace string)

DeleteEsIndices deletes all the indices on es node

func ExecuteEsRequest

func ExecuteEsRequest(esNamespace, httpMethod, api string) ([]byte, error)

ExecuteEsRequest executes rest api request on es node

func GetJaegerSelfProvSimpleProdCR

func GetJaegerSelfProvSimpleProdCR(instanceName, namespace string, nodeCount int32) *v1.Jaeger

GetJaegerSelfProvSimpleProdCR returns self provisioned production simple CR

func GetJaegerSimpleProdWithServerUrlsCR

func GetJaegerSimpleProdWithServerUrlsCR(name, esServerUrls string) *v1.Jaeger

GetJaegerSimpleProdWithServerUrlsCR returns simple production CR with external es server urls

func GetPod

func GetPod(namespace, namePrefix, containsImage string, kubeclient kubernetes.Interface) corev1.Pod

GetPod returns pod name

func ProductionSmokeTest

func ProductionSmokeTest(resourceName string)

ProductionSmokeTest should be used if query and collector are in separate pods

func ProductionSmokeTestWithNamespace

func ProductionSmokeTestWithNamespace(resourceName, smokeTestNamespace string)

ProductionSmokeTestWithNamespace is the same as ProductionSmokeTest but for when you can't use the default namespace

func WaitAndPollForHTTPResponse

func WaitAndPollForHTTPResponse(targetURL string, condition ValidateHTTPResponseFunc) (err error)

WaitAndPollForHTTPResponse will try the targetURL until it gets the desired response or times out

func WaitForCronJob

func WaitForCronJob(t *testing.T, kubeclient kubernetes.Interface, namespace, name string, retryInterval, timeout time.Duration) error

WaitForCronJob checks to see if a given cron job scheduled a job See #WaitForDeployment for the full semantics

func WaitForDaemonSet

func WaitForDaemonSet(t *testing.T, kubeclient kubernetes.Interface, namespace, name string, retryInterval, timeout time.Duration) error

WaitForDaemonSet checks to see if a given daemonset has the desired number of instances available after a specified amount of time See #WaitForDeployment for the full semantics

func WaitForDeployment

func WaitForDeployment(t *testing.T, kubeclient kubernetes.Interface, namespace, name string, replicas int, retryInterval, timeout time.Duration) error

WaitForDeployment waits for a deployment to finish and reports how long the operation took

func WaitForHTTPResponse

func WaitForHTTPResponse(httpClient http.Client, method, url string, response interface{}) (err error)

WaitForHTTPResponse waits for an HTTP valid response

func WaitForIngress

func WaitForIngress(t *testing.T, kubeclient kubernetes.Interface, namespace, name string, retryInterval, timeout time.Duration) (*networkingv1.Ingress, error)

WaitForIngress checks to see if a given ingress' load balancer is ready after a specified amount of time See #WaitForDeployment for the full semantics

func WaitForJob

func WaitForJob(t *testing.T, kubeclient kubernetes.Interface, namespace, name string, retryInterval, timeout time.Duration) error

WaitForJob checks to see if a given job has completed successfully See #WaitForDeployment for the full semantics

func WaitForJobOfAnOwner

func WaitForJobOfAnOwner(t *testing.T, kubeclient kubernetes.Interface, namespace, ownerName string, retryInterval, timeout time.Duration) error

WaitForJobOfAnOwner checks to see if a given job has completed successfully See #WaitForDeployment for the full semantics

func WaitForSecret

func WaitForSecret(secretName, secretNamespace string)

WaitForSecret waits for a secret to be available

func WaitForStatefulset

func WaitForStatefulset(t *testing.T, kubeclient kubernetes.Interface, namespace, name string, retryInterval, timeout time.Duration) error

WaitForStatefulset checks to see if a given statefulset has the desired number of replicas available after a specified amount of time See #WaitForDeployment for the full semantics

Types

type EsIndex

type EsIndex struct {
	UUID        string `json:"uuid"`
	Status      string `json:"status"`
	Index       string `json:"index"`
	Health      string `json:"health"`
	DocsCount   string `json:"docs.count"`
	DocsDeleted string `json:"docs.deleted"`
	StoreSize   string `json:"store.size"`
}

EsIndex struct to map indices data from es rest api response es api: /_cat/indices?format=json

func GetEsIndices

func GetEsIndices(esNamespace string) ([]EsIndex, error)

GetEsIndices return indices from es node

type ValidateHTTPResponseFunc

type ValidateHTTPResponseFunc func(response *http.Response) (done bool, err error)

ValidateHTTPResponseFunc should determine whether the response contains the desired content