framework

package
v0.51.1-rc.0 Latest Latest
Warning

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

 Go to latest Published: Sep 27, 2021 License: Apache-2.0 Imports: 58 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	SECRET    = 0
	CONFIGMAP = 1
)

Variables

View Source 
var (
	CRDCreateRule = rbacv1.PolicyRule{
		APIGroups: []string{"apiextensions.k8s.io"},
		Resources: []string{"customresourcedefinitions"},
		Verbs:     []string{"create"},
	}

	CRDMonitoringRule = rbacv1.PolicyRule{
		APIGroups: []string{"apiextensions.k8s.io"},
		Resources: []string{"customresourcedefinitions"},
		ResourceNames: []string{
			"alertmanagers.monitoring.coreos.com",
			"podmonitors.monitoring.coreos.com",
			"probes.monitoring.coreos.com",
			"prometheuses.monitoring.coreos.com",
			"prometheusrules.monitoring.coreos.com",
			"servicemonitors.monitoring.coreos.com",
			"thanosrulers.monitoring.coreos.com",
		},
		Verbs: []string{"get", "update"},
	}
)
View Source 
var ValidAlertmanagerConfig = `` /* 229-byte string literal not displayed */

Functions

func MakeBasicIngress 

func MakeBasicIngress(serviceName string, servicePort int) *networkv1.Ingress

func MakeConfigMapWithCert added in v0.42.0 

func MakeConfigMapWithCert(kubeClient kubernetes.Interface, ns, name, keyKey, certKey, caKey string,
	keyBytes, certBytes, caBytes []byte) *v1.ConfigMap

func MakeDeployment 

func MakeDeployment(pathToYaml string) (*appsv1.Deployment, error)

func MakeSecretWithCert added in v0.42.0 

func MakeSecretWithCert(ns, name string, keyList []string,
	dataList [][]byte) *corev1.Secret

func MakeService added in v0.42.0 

func MakeService(pathToYaml string) (*v1.Service, error)

func PathToOSFile 

func PathToOSFile(relativePath string) (*os.File, error)

func StartPortForward added in v0.49.0 

func StartPortForward(config *rest.Config, scheme string, name string, ns string, port string) error

StartPortForward initiates a port forwarding connection to a pod on the localhost interface.

StartPortForward blocks until the port forwarding proxy server is ready to receive connections.

func WaitForCRDReady added in v0.42.0 

func WaitForCRDReady(listFunc func(opts metav1.ListOptions) (runtime.Object, error)) error

WaitForCRDReady waits for a Custom Resource Definition to be available for use.

func WaitForHTTPSuccessStatusCode 

func WaitForHTTPSuccessStatusCode(timeout time.Duration, url string) error

Types

type Cert added in v0.42.0 

type Cert struct {
	Filename     string
	ResourceName string
	ResourceType int
}

type ExecOptions added in v0.44.0 

type ExecOptions struct {
	Command       []string
	Namespace     string
	PodName       string
	ContainerName string
	Stdin         io.Reader
	CaptureStdout bool
	CaptureStderr bool
	// If false, whitespace in std{err,out} will be removed.
	PreserveWhitespace bool
}

ExecOptions passed to ExecWithOptions

type FinalizerFn added in v0.47.0 

type FinalizerFn func() error

type Framework 

type Framework struct {
	KubeClient        kubernetes.Interface
	MonClientV1       v1monitoringclient.MonitoringV1Interface
	MonClientV1alpha1 v1alpha1monitoringclient.MonitoringV1alpha1Interface
	APIServerClient   apiclient.Interface
	HTTPClient        *http.Client
	MasterHost        string
	DefaultTimeout    time.Duration
	RestConfig        *rest.Config
	Ctx               context.Context
}

func New 

func New(kubeconfig, opImage string) (*Framework, error)

New setups a test framework and returns it.

func (*Framework) AddAlertingToPrometheus 

func (f *Framework) AddAlertingToPrometheus(p *monitoringv1.Prometheus, ns, name string)

func (*Framework) AddLabelsToNamespace added in v0.49.0 

func (f *Framework) AddLabelsToNamespace(name string, additionalLabels map[string]string) error

func (*Framework) AddRemoteWriteWithTLSToPrometheus added in v0.42.0 

func (f *Framework) AddRemoteWriteWithTLSToPrometheus(p *monitoringv1.Prometheus,
	url string, prwtc PromRemoteWriteTestConfig)

func (*Framework) AlertmanagerConfigSecret 

func (f *Framework) AlertmanagerConfigSecret(ns, name string) (*v1.Secret, error)

func (*Framework) CheckPrometheusFiringAlert added in v0.24.0 

func (f *Framework) CheckPrometheusFiringAlert(ns, svcName, alertName string) (bool, error)

func (*Framework) CheckThanosFiringAlert added in v0.48.0 

func (f *Framework) CheckThanosFiringAlert(ns, svcName, alertName string) (bool, error)

func (*Framework) CreateAlertmanagerAndWaitUntilReady 

func (f *Framework) CreateAlertmanagerAndWaitUntilReady(ns string, a *monitoringv1.Alertmanager) (*monitoringv1.Alertmanager, error)

func (*Framework) CreateBlackBoxExporterAndWaitUntilReady added in v0.42.0 

func (f *Framework) CreateBlackBoxExporterAndWaitUntilReady(ns, name string) error

func (*Framework) CreateCRD added in v0.42.0 

func (f *Framework) CreateCRD(crd *v1.CustomResourceDefinition) error

CreateCRD creates a custom resource definition on the apiserver.

func (*Framework) CreateCRDAndWaitUntilReady added in v0.42.0 

func (f *Framework) CreateCRDAndWaitUntilReady(crdName string, listFunc func(opts metav1.ListOptions) (runtime.Object, error)) error

CreateCRDAndWaitUntilReady creates a Custom Resource Definition from yaml manifest on the apiserver and wait until it is available for use.

func (*Framework) CreateClusterRole added in v0.49.0 

func (f *Framework) CreateClusterRole(relativePath string) (*rbacv1.ClusterRole, error)

func (*Framework) CreateDeployment added in v0.49.0 

func (f *Framework) CreateDeployment(namespace string, d *appsv1.Deployment) error

func (*Framework) CreateIngress added in v0.49.0 

func (f *Framework) CreateIngress(namespace string, i *networkv1.Ingress) error

func (*Framework) CreateNamespace added in v0.49.0 

func (f *Framework) CreateNamespace(t *testing.T, ctx *TestCtx) string

func (*Framework) CreatePrometheusAndWaitUntilReady 

func (f *Framework) CreatePrometheusAndWaitUntilReady(ns string, p *monitoringv1.Prometheus) (*monitoringv1.Prometheus, error)

func (*Framework) CreatePrometheusOperator added in v0.24.0 

func (f *Framework) CreatePrometheusOperator(ns, opImage string, namespaceAllowlist,
	namespaceDenylist, prometheusInstanceNamespaces, alertmanagerInstanceNamespaces []string,
	createRuleAdmissionHooks, createClusterRoleBindings bool) ([]FinalizerFn, error)

CreatePrometheusOperator creates a Prometheus Operator Kubernetes Deployment inside the specified namespace using the specified operator image. In addition one can specify the namespaces to watch, which defaults to all namespaces. Returns the CA, which can bs used to access the operator over TLS

func (*Framework) CreateRoleBinding added in v0.49.0 

func (f *Framework) CreateRoleBinding(ns string, relativePath string) (FinalizerFn, error)

func (*Framework) CreateRoleBindingForSubjectNamespace added in v0.49.0 

func (f *Framework) CreateRoleBindingForSubjectNamespace(ns, subjectNs string, relativePath string) (FinalizerFn, error)

func (*Framework) CreateRule added in v0.20.0 

func (f *Framework) CreateRule(ns string, ar *monitoringv1.PrometheusRule) (*monitoringv1.PrometheusRule, error)

func (*Framework) CreateSecretWithCert added in v0.49.0 

func (f *Framework) CreateSecretWithCert(certBytes, keyBytes []byte, ns, name string) error

func (*Framework) CreateServiceAndWaitUntilReady added in v0.49.0 

func (f *Framework) CreateServiceAndWaitUntilReady(namespace string, service *v1.Service) (FinalizerFn, error)

func (*Framework) CreateSilence added in v0.18.1 

func (f *Framework) CreateSilence(ns, n string) (string, error)

func (*Framework) CreateThanosRulerAndWaitUntilReady added in v0.42.0 

func (f *Framework) CreateThanosRulerAndWaitUntilReady(ns string, tr *monitoringv1.ThanosRuler) (*monitoringv1.ThanosRuler, error)

func (*Framework) DeleteAlertmanagerAndWaitUntilGone 

func (f *Framework) DeleteAlertmanagerAndWaitUntilGone(ns, name string) error

func (*Framework) DeleteClusterRole added in v0.49.0 

func (f *Framework) DeleteClusterRole(relativePath string) error

func (*Framework) DeleteClusterRoleBinding added in v0.49.0 

func (f *Framework) DeleteClusterRoleBinding(ns string, relativePath string) error

func (*Framework) DeleteDeployment added in v0.49.0 

func (f *Framework) DeleteDeployment(namespace, name string) error

func (*Framework) DeleteNamespace added in v0.49.0 

func (f *Framework) DeleteNamespace(name string) error

func (*Framework) DeleteNginxIngressControllerIncDefaultBackend added in v0.49.0 

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

func (*Framework) DeletePrometheusAndWaitUntilGone 

func (f *Framework) DeletePrometheusAndWaitUntilGone(ns, name string) error

func (*Framework) DeleteRoleBinding added in v0.49.0 

func (f *Framework) DeleteRoleBinding(ns string, relativePath string) error

func (*Framework) DeleteRule added in v0.22.0 

func (f *Framework) DeleteRule(ns string, r string) error

func (*Framework) DeleteServiceAccount added in v0.49.0 

func (f *Framework) DeleteServiceAccount(namespace string, relativePath string) error

func (*Framework) DeleteServiceAndWaitUntilGone added in v0.49.0 

func (f *Framework) DeleteServiceAndWaitUntilGone(namespace string, serviceName string) error

func (*Framework) DeleteThanosRulerAndWaitUntilGone added in v0.42.0 

func (f *Framework) DeleteThanosRulerAndWaitUntilGone(ns, name string) error

func (*Framework) ExecWithOptions added in v0.44.0 

func (f *Framework) ExecWithOptions(options ExecOptions) (string, string, error)

ExecWithOptions executes a command in the specified container, returning stdout, stderr and error. `options` allowed for additional parameters to be passed. Inspired by https://github.com/kubernetes/kubernetes/blob/dde6e8e7465468c32642659cb708a5cc922add64/test/e2e/framework/exec_util.go#L36-L51

func (*Framework) GetActiveTargets 

func (f *Framework) GetActiveTargets(ns, svcName string) ([]*Target, error)

func (*Framework) GetAlertmanagerMetrics added in v0.42.0 

func (f *Framework) GetAlertmanagerMetrics(ns, n string) (textparse.Parser, error)

func (*Framework) GetAlertmanagerStatus added in v0.29.0 

func (f *Framework) GetAlertmanagerStatus(ns, n string) (models.AlertmanagerStatus, error)

func (*Framework) GetCRD added in v0.42.0 

func (f *Framework) GetCRD(name string) (*v1.CustomResourceDefinition, error)

GetCRD gets a custom resource definition from the apiserver.

func (*Framework) GetDeployment added in v0.49.0 

func (f *Framework) GetDeployment(ns, name string) (*appsv1.Deployment, error)

func (*Framework) GetHealthyTargets added in v0.42.0 

func (f *Framework) GetHealthyTargets(ns, svcName string) ([]*Target, error)

func (*Framework) GetIngressIP added in v0.49.0 

func (f *Framework) GetIngressIP(namespace string, ingressName string) (*string, error)

func (*Framework) GetLogs added in v0.49.0 

func (f *Framework) GetLogs(namespace string, podName, containerName string) (string, error)

func (*Framework) GetPodRestartCount added in v0.24.0 

func (f *Framework) GetPodRestartCount(ns, podName string) (map[string]int32, error)

GetPodRestartCount returns a map of container names and their restart counts for a given pod.

func (*Framework) GetRule added in v0.42.0 

func (f *Framework) GetRule(ns, name string) (*monitoringv1.PrometheusRule, error)

func (*Framework) GetSilences added in v0.18.1 

func (f *Framework) GetSilences(ns, n string) (models.GettableSilences, error)

func (*Framework) ListCRDs added in v0.42.0 

func (f *Framework) ListCRDs() (*v1.CustomResourceDefinitionList, error)

ListCRDs gets a list of custom resource definitions from the apiserver.

func (*Framework) MakeAlertmanagerService 

func (f *Framework) MakeAlertmanagerService(name, group string, serviceType v1.ServiceType) *v1.Service

func (*Framework) MakeAndCreateFiringRule added in v0.20.0 

func (f *Framework) MakeAndCreateFiringRule(ns, name, alertName string) (*monitoringv1.PrometheusRule, error)

func (*Framework) MakeAndCreateInvalidRule added in v0.42.0 

func (f *Framework) MakeAndCreateInvalidRule(ns, name, alertName string) (*monitoringv1.PrometheusRule, error)

func (*Framework) MakeBasicAlertmanager 

func (f *Framework) MakeBasicAlertmanager(name string, replicas int32) *monitoringv1.Alertmanager

func (*Framework) MakeBasicPodMonitor added in v0.43.0 

func (f *Framework) MakeBasicPodMonitor(name string) *monitoringv1.PodMonitor

func (*Framework) MakeBasicPrometheus 

func (f *Framework) MakeBasicPrometheus(ns, name, group string, replicas int32) *monitoringv1.Prometheus

func (*Framework) MakeBasicRule added in v0.20.0 

func (f *Framework) MakeBasicRule(ns, name string, groups []monitoringv1.RuleGroup) *monitoringv1.PrometheusRule

func (*Framework) MakeBasicServiceMonitor 

func (f *Framework) MakeBasicServiceMonitor(name string) *monitoringv1.ServiceMonitor

func (*Framework) MakeBasicStaticProbe added in v0.42.0 

func (f *Framework) MakeBasicStaticProbe(name, url string, targets []string) *monitoringv1.Probe

func (*Framework) MakeBasicThanosRuler added in v0.42.0 

func (f *Framework) MakeBasicThanosRuler(name string, replicas int32, queryEndpoint string) *monitoringv1.ThanosRuler

func (*Framework) MakeBlackBoxExporterService added in v0.42.0 

func (f *Framework) MakeBlackBoxExporterService(ns, name string) *v1.Service

func (*Framework) MakeCRD added in v0.42.0 

func (f *Framework) MakeCRD(pathToYaml string) (*v1.CustomResourceDefinition, error)

MakeCRD creates a CustomResourceDefinition object from yaml manifest.

func (*Framework) MakeEchoDeployment added in v0.42.0 

func (f *Framework) MakeEchoDeployment(group string) *appsv1.Deployment

func (*Framework) MakeEchoService added in v0.42.0 

func (f *Framework) MakeEchoService(name, group string, serviceType v1.ServiceType) *v1.Service

func (*Framework) MakePrometheusService 

func (f *Framework) MakePrometheusService(name, group string, serviceType v1.ServiceType) *v1.Service

func (*Framework) MakeThanosQuerierService added in v0.21.0 

func (f *Framework) MakeThanosQuerierService(name string) *v1.Service

func (*Framework) MakeThanosRulerService added in v0.48.0 

func (f *Framework) MakeThanosRulerService(name, group string, serviceType v1.ServiceType) *v1.Service

func (*Framework) NewTestCtx 

func (f *Framework) NewTestCtx(t *testing.T) *TestCtx

func (*Framework) PollAlertmanagerConfiguration added in v0.48.0 

func (f *Framework) PollAlertmanagerConfiguration(ns, amName string, conditions ...func(config string) error) error

PollAlertmanagerConfiguration retrieves the Alertmanager configuration via the Alertmanager's API and checks that all conditions return without error. It will retry every 10 second for 5 minutes before giving up.

func (*Framework) PrintEvents added in v0.22.0 

func (f *Framework) PrintEvents() error

PrintEvents prints the Kubernetes events to standard out.

func (*Framework) PrintPodLogs added in v0.22.0 

func (f *Framework) PrintPodLogs(ns, p string) error

PrintPodLogs prints the logs of a specified Pod

func (*Framework) PrintPrometheusLogs added in v0.43.0 

func (f *Framework) PrintPrometheusLogs(t *testing.T, p *monitoringv1.Prometheus)

PrintPrometheusLogs prints the logs for each Prometheus replica.

func (*Framework) PrometheusQuery added in v0.51.0 

func (f *Framework) PrometheusQuery(ns, svcName, query string) ([]PrometheusQueryResult, error)

func (*Framework) PrometheusSVCGetRequest added in v0.42.0 

func (f *Framework) PrometheusSVCGetRequest(ns, svcName, endpoint string, query map[string]string) ([]byte, error)

func (*Framework) ProxyGetPod added in v0.49.0 

func (f *Framework) ProxyGetPod(namespace, podName, path string) *rest.Request

func (*Framework) ProxyPostPod added in v0.49.0 

func (f *Framework) ProxyPostPod(namespace, podName, path, body string) *rest.Request

func (*Framework) RemoveLabelsFromNamespace added in v0.49.0 

func (f *Framework) RemoveLabelsFromNamespace(name string, labels ...string) error

func (*Framework) SecretFromYaml 

func (f *Framework) SecretFromYaml(filepath string) (*v1.Secret, error)

func (*Framework) SendAlertToAlertmanager added in v0.24.0 

func (f *Framework) SendAlertToAlertmanager(ns, n string) error

SendAlertToAlertmanager sends an alert to the alertmanager in the given namespace (ns) with the given name (n).

func (*Framework) SetupNginxIngressControllerIncDefaultBackend added in v0.49.0 

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

func (*Framework) SetupPrometheusRBAC added in v0.49.0 

func (f *Framework) SetupPrometheusRBAC(t *testing.T, ctx *TestCtx, ns string)

func (*Framework) SetupPrometheusRBACGlobal added in v0.49.0 

func (f *Framework) SetupPrometheusRBACGlobal(t *testing.T, ctx *TestCtx, ns string)

func (*Framework) ThanosSVCGetRequest added in v0.48.0 

func (f *Framework) ThanosSVCGetRequest(ns, svcName, endpoint string, query map[string]string) ([]byte, error)

func (*Framework) UpdateAlertmanagerAndWaitUntilReady 

func (f *Framework) UpdateAlertmanagerAndWaitUntilReady(ns string, a *monitoringv1.Alertmanager) (*monitoringv1.Alertmanager, error)

func (*Framework) UpdateClusterRole added in v0.49.0 

func (f *Framework) UpdateClusterRole(clusterRole *rbacv1.ClusterRole) error

func (*Framework) UpdateDeployment added in v0.49.0 

func (f *Framework) UpdateDeployment(deployment *appsv1.Deployment) (*appsv1.Deployment, error)

func (*Framework) UpdatePrometheusAndWaitUntilReady 

func (f *Framework) UpdatePrometheusAndWaitUntilReady(ns string, p *monitoringv1.Prometheus) (*monitoringv1.Prometheus, error)

func (*Framework) UpdateRule added in v0.20.0 

func (f *Framework) UpdateRule(ns string, ar *monitoringv1.PrometheusRule) (*monitoringv1.PrometheusRule, error)

func (*Framework) UpdateThanosRulerAndWaitUntilReady added in v0.42.0 

func (f *Framework) UpdateThanosRulerAndWaitUntilReady(ns string, tr *monitoringv1.ThanosRuler) (*monitoringv1.ThanosRuler, error)

func (*Framework) WaitForActiveTargets added in v0.42.0 

func (f *Framework) WaitForActiveTargets(ns, svcName string, amount int) error

WaitForActiveTargets waits for a number of targets to be configured.

func (*Framework) WaitForAlertmanagerConfigToBeReloaded added in v0.42.0 

func (f *Framework) WaitForAlertmanagerConfigToBeReloaded(ns, amName string, previousReloadTimestamp time.Time) error

func (*Framework) WaitForAlertmanagerConfigToContainString added in v0.20.0 

func (f *Framework) WaitForAlertmanagerConfigToContainString(ns, amName, expected string) error

func (*Framework) WaitForAlertmanagerInitialized added in v0.42.0 

func (f *Framework) WaitForAlertmanagerInitialized(ns, name string, amountPeers int, forceEnableClusterMode bool) error

func (*Framework) WaitForAlertmanagerReady 

func (f *Framework) WaitForAlertmanagerReady(ns, name string, replicas int, forceEnableClusterMode bool) error

WaitForAlertmanagerReady waits for each individual pod as well as the cluster as a whole to be ready.

func (*Framework) WaitForConfigMapExist added in v0.20.0 

func (f *Framework) WaitForConfigMapExist(ns, name string) (*v1.ConfigMap, error)

func (*Framework) WaitForConfigMapNotExist added in v0.20.0 

func (f *Framework) WaitForConfigMapNotExist(ns, name string) error

func (*Framework) WaitForDiscoveryWorking added in v0.42.0 

func (f *Framework) WaitForDiscoveryWorking(ns, svcName, prometheusName string) error

func (*Framework) WaitForHealthyTargets added in v0.42.0 

func (f *Framework) WaitForHealthyTargets(ns, svcName string, amount int) error

WaitForHealthyTargets waits for a number of targets to be configured and healthy.

func (*Framework) WaitForPodsReady added in v0.49.0 

func (f *Framework) WaitForPodsReady(namespace string, timeout time.Duration, expectedReplicas int, opts metav1.ListOptions) error

WaitForPodsReady waits for a selection of Pods to be running and each container to pass its readiness check.

func (*Framework) WaitForPodsRunImage added in v0.49.0 

func (f *Framework) WaitForPodsRunImage(namespace string, expectedReplicas int, image string, opts metav1.ListOptions) error

func (*Framework) WaitForPrometheusFiringAlert added in v0.19.0 

func (f *Framework) WaitForPrometheusFiringAlert(ns, svcName, alertName string) error

func (*Framework) WaitForPrometheusReady 

func (f *Framework) WaitForPrometheusReady(p *monitoringv1.Prometheus, timeout time.Duration) error

func (*Framework) WaitForPrometheusRunImageAndReady 

func (f *Framework) WaitForPrometheusRunImageAndReady(ns string, p *monitoringv1.Prometheus) error

func (*Framework) WaitForRule added in v0.20.0 

func (f *Framework) WaitForRule(ns, name string) error

WaitForRule waits for a rule file with a given name to exist in a given namespace.

func (*Framework) WaitForServiceReady added in v0.49.0 

func (f *Framework) WaitForServiceReady(namespace string, serviceName string) error

func (*Framework) WaitForThanosFiringAlert added in v0.48.0 

func (f *Framework) WaitForThanosFiringAlert(ns, svcName, alertName string) error

func (*Framework) WaitForThanosRulerReady added in v0.42.0 

func (f *Framework) WaitForThanosRulerReady(tr *monitoringv1.ThanosRuler, timeout time.Duration) error

func (*Framework) WaitUntilDeploymentGone added in v0.49.0 

func (f *Framework) WaitUntilDeploymentGone(kubeClient kubernetes.Interface, namespace, name string, timeout time.Duration) error

type Key added in v0.42.0 

type Key struct {
	Filename   string
	SecretName string
}

type PromRemoteWriteTestConfig added in v0.42.0 

type PromRemoteWriteTestConfig struct {
	Name               string
	ClientKey          Key
	ClientCert         Cert
	CA                 Cert
	ExpectedInLogs     string
	InsecureSkipVerify bool
	ShouldSuccess      bool
}

type PrometheusQueryAPIResponse added in v0.42.0 

type PrometheusQueryAPIResponse struct {
	Status string               `json:"status"`
	Data   *PrometheusQueryData `json:"data"`
}

type PrometheusQueryData added in v0.42.0 

type PrometheusQueryData struct {
	ResultType string                  `json:"resultType"`
	Result     []PrometheusQueryResult `json:"result"`
}

type PrometheusQueryResult added in v0.42.0 

type PrometheusQueryResult struct {
	Metric map[string]string `json:"metric"`
	Value  []interface{}     `json:"value"`
}

type Target 

type Target struct {
	ScrapeURL string            `json:"scrapeUrl"`
	Labels    map[string]string `json:"labels"`
	LastError string            `json:"lastError"`
	Health    targetHealth      `json:"health"`
}

type TestCtx 

type TestCtx struct {
	ID string
	// contains filtered or unexported fields
}

func (*TestCtx) AddFinalizerFn 

func (ctx *TestCtx) AddFinalizerFn(fn FinalizerFn)

func (*TestCtx) Cleanup 

func (ctx *TestCtx) Cleanup(t *testing.T)

func (*TestCtx) GetObjID 

func (ctx *TestCtx) GetObjID() string

GetObjID returns an ascending ID based on the length of cleanUpFns. It is based on the premise that every new object also appends a new finalizerFn on cleanUpFns. This can e.g. be used to create multiple namespaces in the same test context.

type ThanosAlert added in v0.48.0 

type ThanosAlert struct {
	Labels      map[string]string `json:"labels"`
	Annotations map[string]string `json:"annotations"`
	State       string            `json:"state"`
	ActiveAt    time.Time         `json:"activeAt"`
	Value       string            `json:"value"`
}

type ThanosAlertsAPIResponse added in v0.48.0 

type ThanosAlertsAPIResponse struct {
	Status string            `json:"status"`
	Data   *ThanosAlertsData `json:"data"`
}

type ThanosAlertsData added in v0.48.0 

type ThanosAlertsData struct {
	Alerts []ThanosAlert `json:"alerts"`
}

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.