utils

Documentation

Index

• Constants
• Variables
• func ConfigMap(ns, name, data string, labels map[string]string) kubev1.ConfigMap
• func CreateConfigMap(cm kubev1.ConfigMap) error
• func CreateNs(ns string) error
• func CurlArgs(opts setup.CurlOpts) []string
• func DeleteNs(ns string) error
• func DeployBookInfoAppmesh(namespace string) error
• func DeployBookInfoIstio(namespace string) error
• func DeployBookInfoWithInject(namespace, istioNamespace string) error
• func DeployPrometheus(kube kubernetes.Interface, namespace string) error
• func DeployTestRunner(namespace string) error
• func DeployTestRunnerWithIstioInject(namespace, istioNamespace string) error
• func DeployTestRunnerWithLinkerdInject(namespace string) error
• func DeployTestService(namespace string) error
• func HelmTemplate(args ...string) (string, error)
• func IstioInject(istioNamespace, input string) (string, error)
• func Kubectl(stdin io.Reader, args ...string) error
• func KubectlApply(namespace, yamlStr string) error
• func KubectlCtx(ctx context.Context, stdin io.Reader, args ...string) error
• func KubectlDelete(namespace, yamlStr string) error
• func KubectlPortForward(ctx context.Context, namespace, deployment string, port int) error
• func LinkerdInject(input string) (string, error)
• func MustCreateConfigMap(cm kubev1.ConfigMap)
• func MustCreateNs(ns string)
• func MustDeleteNs(ns string)
• func MustProjectRoot() string
• func MustTestFile(filename string) string
• func MustTestFiles() string
• func PodExec(podLabels map[string]string, namespace string, command ...string) (string, error)
• func ProjectRoot() (string, error)
• func TeardownPrometheus(kube kubernetes.Interface, namespace string) error
• func TestRunnerCurl(namespace string, opts setup.CurlOpts) (string, error)
• func TestRunnerCurlEventuallyShouldRespond(ctx context.Context, testrunnerNamespace string, opts setup.CurlOpts, ...)

Constants

const (
	AppmeshBookInfoYaml = bookinfoYaml + appmeshServices
)

const TestRunnerYaml = `` /* 981-byte string literal not displayed */

Variables

var IstioBookInfoYaml = func() string {
	bookinfoYamlFile := MustTestFile("bookinfo.yaml")
	b, err := ioutil.ReadFile(bookinfoYamlFile)
	if err != nil {
		log.Fatalf("failed to read bookinfo for test: %v", err)
	}
	return string(b)
}()

loads bookinfo from <root>/test/e2e/files/bookinfo.yaml

var TestServiceYaml = func() string {
	file := MustTestFile("test-service.yaml")
	b, err := ioutil.ReadFile(file)
	if err != nil {
		log.Fatalf("failed to read file for test: %v", err)
	}
	return string(b)
}()

loads test-service from <root>/test/e2e/files/test-service.yaml

Functions

func ConfigMap

func ConfigMap(ns, name, data string, labels map[string]string) kubev1.ConfigMap

func CreateConfigMap

func CreateConfigMap(cm kubev1.ConfigMap) error

func CreateNs

func CreateNs(ns string) error

func CurlArgs

func CurlArgs(opts setup.CurlOpts) []string

func DeleteNs

func DeleteNs(ns string) error

func DeployBookInfoAppmesh

func DeployBookInfoAppmesh(namespace string) error

func DeployBookInfoIstio

func DeployBookInfoIstio(namespace string) error

func DeployBookInfoWithInject

func DeployBookInfoWithInject(namespace, istioNamespace string) error

func DeployPrometheus

func DeployPrometheus(kube kubernetes.Interface, namespace string) error

func DeployTestRunner

func DeployTestRunner(namespace string) error

func DeployTestRunnerWithIstioInject

func DeployTestRunnerWithIstioInject(namespace, istioNamespace string) error

func DeployTestRunnerWithLinkerdInject

func DeployTestRunnerWithLinkerdInject(namespace string) error

func DeployTestService

func DeployTestService(namespace string) error

func HelmTemplate

func HelmTemplate(args ...string) (string, error)

func IstioInject

func IstioInject(istioNamespace, input string) (string, error)

func Kubectl

func Kubectl(stdin io.Reader, args ...string) error

func KubectlApply

func KubectlApply(namespace, yamlStr string) error

func KubectlCtx

func KubectlCtx(ctx context.Context, stdin io.Reader, args ...string) error

func KubectlDelete

func KubectlDelete(namespace, yamlStr string) error

func KubectlPortForward

func KubectlPortForward(ctx context.Context, namespace, deployment string, port int) error

func LinkerdInject

func LinkerdInject(input string) (string, error)

func MustCreateConfigMap

func MustCreateConfigMap(cm kubev1.ConfigMap)

func MustCreateNs

func MustCreateNs(ns string)

func MustDeleteNs

func MustDeleteNs(ns string)

func MustProjectRoot

func MustProjectRoot() string

func MustTestFile

func MustTestFile(filename string) string

func MustTestFiles

func MustTestFiles() string

func PodExec

func PodExec(podLabels map[string]string, namespace string, command ...string) (string, error)

TestRunner executes a command inside the TestRunner container

func ProjectRoot

func ProjectRoot() (string, error)

returns absolute path of project root

func TeardownPrometheus

func TeardownPrometheus(kube kubernetes.Interface, namespace string) error

func TestRunnerCurl

func TestRunnerCurl(namespace string, opts setup.CurlOpts) (string, error)

func TestRunnerCurlEventuallyShouldRespond

func TestRunnerCurlEventuallyShouldRespond(ctx context.Context, testrunnerNamespace string, opts setup.CurlOpts, substr string, timeout time.Duration)