helpers

Documentation

Index

• Constants
• func Certificate() string
• func EventuallyObjectDeleted(getter ObjectGetter, intervals ...interface{})
• func EventuallyObjectDeletedWithOffset(offset int, getter ObjectGetter, intervals ...interface{})
• func EventuallyResourceAccepted(getter InputResourceGetter, intervals ...interface{})
• func EventuallyResourceDeleted(getter InputResourceGetter, intervals ...interface{})
• func EventuallyResourceDeletedWithOffset(offset int, getter InputResourceGetter, intervals ...interface{})
• func EventuallyResourceRejected(getter InputResourceGetter, intervals ...interface{})
• func EventuallyResourceStatusMatchesState(offset int, getter InputResourceGetter, desiredStatusState core.Status_State, ...)
• func EventuallyResourceWarning(getter InputResourceGetter, intervals ...interface{})
• func GetCallerDirectory(skip ...int) (string, error)
• func GetCerts(params Params) (string, string)
• func GetKubeSecret(name, namespace string) *kubev1.Secret
• func GlooDir() string
• func GlooHelmChartDir() string
• func GlooInstallDir() string
• func GlooTestContainersDir() string
• func KubeDump(namespaces ...string) (string, error)
• func KubeDumpOnFail(out io.Writer, namespaces ...string) func()
• func MakeGatewayRoute(pathType, length int) *gatwayv1.Route
• func MakeMatcher(pathType, length int) *matchers.Matcher
• func MakeMultiMatcherRoute(pathType1, length1, pathType2, length2 int) *v1.Route
• func MakeRoute(pathType, length int) *v1.Route
• func Must(err error)
• func MustReadFile(name string) []byte
• func PrintDockerState()
• func PrintGlooDebugLogs()
• func PrintKubeState()
• func PrintProcessState()
• func PrivateKey() string
• func ReadMetricByLabel(metricName string, labelKey string, labelValue string) (int, error)
• func RegisterGlooDebugLogPrintHandler()
• func RegisterGlooDebugLogPrintHandlerAndClearLogs()
• func WriteDefaultGateways(writeNamespace string, gatewayClient v1.GatewayClient) error
• func WriteDefaultHybridGateway(writeNamespace string, gatewayClient v1.GatewayClient) error
• type InputResourceGetter
• type InputResourceListGetter
• type ObjectGetter
• type Params

Constants

const (
	ExactPath = iota
	PrefixPath
	RegexPath
)

Functions

func Certificate

func Certificate() string

func EventuallyObjectDeleted

func EventuallyObjectDeleted(getter ObjectGetter, intervals ...interface{})

func EventuallyObjectDeletedWithOffset

func EventuallyObjectDeletedWithOffset(offset int, getter ObjectGetter, intervals ...interface{})

func EventuallyResourceAccepted

func EventuallyResourceAccepted(getter InputResourceGetter, intervals ...interface{})

func EventuallyResourceDeleted

func EventuallyResourceDeleted(getter InputResourceGetter, intervals ...interface{})

func EventuallyResourceDeletedWithOffset

func EventuallyResourceDeletedWithOffset(offset int, getter InputResourceGetter, intervals ...interface{})

func EventuallyResourceRejected

func EventuallyResourceRejected(getter InputResourceGetter, intervals ...interface{})

func EventuallyResourceStatusMatchesState

func EventuallyResourceStatusMatchesState(offset int, getter InputResourceGetter, desiredStatusState core.Status_State, intervals ...interface{})

func EventuallyResourceWarning

func EventuallyResourceWarning(getter InputResourceGetter, intervals ...interface{})

func GetCallerDirectory

func GetCallerDirectory(skip ...int) (string, error)

returns absolute path to the currently executing directory

func GetCerts

func GetCerts(params Params) (string, string)

func GetKubeSecret

func GetKubeSecret(name, namespace string) *kubev1.Secret

func GlooDir

func GlooDir() string

func GlooHelmChartDir

func GlooHelmChartDir() string

func GlooInstallDir

func GlooInstallDir() string

func GlooTestContainersDir

func GlooTestContainersDir() string

func KubeDump

func KubeDump(namespaces ...string) (string, error)

dump all data from the kube cluster

func KubeDumpOnFail

func KubeDumpOnFail(out io.Writer, namespaces ...string) func()

func MakeGatewayRoute

func MakeGatewayRoute(pathType, length int) *gatwayv1.Route

func MakeMatcher

func MakeMatcher(pathType, length int) *matchers.Matcher

func MakeMultiMatcherRoute

func MakeMultiMatcherRoute(pathType1, length1, pathType2, length2 int) *v1.Route

func MakeRoute

func MakeRoute(pathType, length int) *v1.Route

func Must

func Must(err error)

func MustReadFile

func MustReadFile(name string) []byte

returns absolute path to the currently executing directory

func PrintDockerState

func PrintDockerState()

func PrintGlooDebugLogs

func PrintGlooDebugLogs()

func PrintKubeState

func PrintKubeState()

func PrintProcessState

func PrintProcessState()

func PrivateKey

func PrivateKey() string

func ReadMetricByLabel

func ReadMetricByLabel(metricName string, labelKey string, labelValue string) (int, error)

ReadMetricByLabel looks up the specified metricName and returns the latest data recorded for the time series with the specified label key/value pair.

If the metric has not yet been registered, this function will fail. If the metric has been registered, but there is not yet any time series data recorded with the label key/value provided, then an error is returned. The error response allows tests to distinguish "the metric was never recorded" from "a value of 0 was recorded"

func RegisterGlooDebugLogPrintHandler

func RegisterGlooDebugLogPrintHandler()

func RegisterGlooDebugLogPrintHandlerAndClearLogs

func RegisterGlooDebugLogPrintHandlerAndClearLogs()

func WriteDefaultGateways

func WriteDefaultGateways(writeNamespace string, gatewayClient v1.GatewayClient) error

func WriteDefaultHybridGateway

func WriteDefaultHybridGateway(writeNamespace string, gatewayClient v1.GatewayClient) error

Types

type InputResourceGetter

type InputResourceGetter func() (resources.InputResource, error)

type InputResourceListGetter

type InputResourceListGetter func() (resources.InputResourceList, error)

type ObjectGetter

type ObjectGetter func() (client.Object, error)

type Params

type Params struct {
	Hosts      string         // Comma-separated hostnames and IPs to generate a certificate for
	ValidFrom  *time.Time     // Creation date
	ValidFor   *time.Duration // Duration that certificate is valid for
	IsCA       bool           // whether this cert should be its own Certificate Authority
	RsaBits    int            // Size of RSA key to generate. Ignored if EcdsaCurve is set
	EcdsaCurve string         // ECDSA curve to use to generate a key. Valid values are P224, P256 (recommended), P384, P521
}