framework

package
v0.23.2 Latest Latest
Warning

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

 Go to latest Published: Aug 23, 2018 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ValidAlertmanagerConfig = `` /* 229-byte string literal not displayed */

Functions

func AddLabelsToNamespace added in v0.19.0 

func AddLabelsToNamespace(kubeClient kubernetes.Interface, name string, additionalLabels map[string]string) error

func CreateClusterRole 

func CreateClusterRole(kubeClient kubernetes.Interface, relativePath string) error

func CreateClusterRoleBinding 

func CreateClusterRoleBinding(kubeClient kubernetes.Interface, ns string, relativePath string) (finalizerFn, error)

func CreateDeployment 

func CreateDeployment(kubeClient kubernetes.Interface, namespace string, d *appsv1.Deployment) error

func CreateIngress 

func CreateIngress(kubeClient kubernetes.Interface, namespace string, i *v1beta1.Ingress) error

func CreateNamespace 

func CreateNamespace(kubeClient kubernetes.Interface, name string) (*v1.Namespace, error)

func CreateRoleBinding 

func CreateRoleBinding(kubeClient kubernetes.Interface, ns string, relativePath string) (finalizerFn, error)

func CreateServiceAccount 

func CreateServiceAccount(kubeClient kubernetes.Interface, namespace string, relativPath string) (finalizerFn, error)

func CreateServiceAndWaitUntilReady 

func CreateServiceAndWaitUntilReady(kubeClient kubernetes.Interface, namespace string, service *v1.Service) (finalizerFn, error)

func DeleteClusterRole 

func DeleteClusterRole(kubeClient kubernetes.Interface, relativePath string) error

func DeleteClusterRoleBinding 

func DeleteClusterRoleBinding(kubeClient kubernetes.Interface, relativePath string) error

func DeleteDeployment 

func DeleteDeployment(kubeClient kubernetes.Interface, namespace, name string) error

func DeleteNamespace 

func DeleteNamespace(kubeClient kubernetes.Interface, name string) error

func DeleteNginxIngressControllerIncDefaultBackend 

func DeleteNginxIngressControllerIncDefaultBackend(kubeClient kubernetes.Interface, namespace string) error

func DeleteRoleBinding 

func DeleteRoleBinding(kubeClient kubernetes.Interface, ns string, relativePath string) error

func DeleteServiceAccount 

func DeleteServiceAccount(kubeClient kubernetes.Interface, namespace string, relativPath string) error

func DeleteServiceAndWaitUntilGone 

func DeleteServiceAndWaitUntilGone(kubeClient kubernetes.Interface, namespace string, serviceName string) error

func GetIngressIP 

func GetIngressIP(kubeClient kubernetes.Interface, namespace string, ingressName string) (*string, error)

func GetLogs 

func GetLogs(kubeClient kubernetes.Interface, namespace string, podName, containerName string) (string, error)

func MakeBasicIngress 

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

func MakeDeployment 

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

func PathToOSFile 

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

func ProxyGetPod 

func ProxyGetPod(kubeClient kubernetes.Interface, namespace, podName, port, path string) *rest.Request

func ProxyPostPod added in v0.18.1 

func ProxyPostPod(kubeClient kubernetes.Interface, namespace, podName, port, path, body string) *rest.Request

func SetupNginxIngressControllerIncDefaultBackend 

func SetupNginxIngressControllerIncDefaultBackend(kubeClient kubernetes.Interface, namespace string) error

func WaitForHTTPSuccessStatusCode 

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

func WaitForPodsReady 

func WaitForPodsReady(kubeClient kubernetes.Interface, 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 WaitForPodsRunImage 

func WaitForPodsRunImage(kubeClient kubernetes.Interface, namespace string, expectedReplicas int, image string, opts metav1.ListOptions) error

func WaitForServiceReady 

func WaitForServiceReady(kubeClient kubernetes.Interface, namespace string, serviceName string) error

func WaitUntilDeploymentGone 

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

Types

type Framework 

type Framework struct {
	KubeClient        kubernetes.Interface
	MonClientV1       monitoringv1.MonitoringV1Interface
	MonClientV1alpha1 monitoringv1alpha1.MonitoringV1alpha1Interface
	HTTPClient        *http.Client
	MasterHost        string
	Namespace         *v1.Namespace
	OperatorPod       *v1.Pod
	DefaultTimeout    time.Duration
}

func New 

func New(ns, 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) AlertmanagerConfigSecret 

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

func (*Framework) CreateAlertmanagerAndWaitUntilReady 

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

func (*Framework) CreatePrometheusAndWaitUntilReady 

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

func (*Framework) CreateRule added in v0.20.0 

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

func (*Framework) CreateSilence added in v0.18.1 

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

func (*Framework) DeleteAlertmanagerAndWaitUntilGone 

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

func (*Framework) DeletePrometheusAndWaitUntilGone 

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

func (*Framework) DeleteRule added in v0.22.0 

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

func (*Framework) GetActiveTargets 

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

func (*Framework) GetAlertmanagerConfig 

func (f *Framework) GetAlertmanagerConfig(ns, n string) (amAPIStatusResp, error)

func (*Framework) GetRestartCount added in v0.23.0 

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

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

func (*Framework) GetSilences added in v0.18.1 

func (f *Framework) GetSilences(ns, n string) ([]amAPISil, error)

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) MakeBasicAlertmanager 

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

func (*Framework) MakeBasicAlertmanagerV1alpha1 

func (f *Framework) MakeBasicAlertmanagerV1alpha1(name string, replicas int32) *v1alpha1.Alertmanager

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) MakeBasicServiceMonitorV1alpha1 

func (f *Framework) MakeBasicServiceMonitorV1alpha1(name string) *v1alpha1.ServiceMonitor

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) MakeThanosService added in v0.21.0 

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

func (*Framework) NewTestCtx 

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

func (*Framework) Poll 

func (f *Framework) Poll(timeout, pollInterval time.Duration, pollFunc func() (bool, error)) error

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) QueryPrometheusSVC 

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

func (*Framework) SecretFromYaml 

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

func (*Framework) Setup 

func (f *Framework) Setup(opImage string) error

func (*Framework) Teardown 

func (f *Framework) Teardown() error

Teardown tears down a previously initialized test environment.

func (*Framework) UpdateAlertmanagerAndWaitUntilReady 

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

func (*Framework) UpdatePrometheusAndWaitUntilReady 

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

func (*Framework) UpdateRule added in v0.20.0 

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

func (*Framework) WaitForAlertmanagerConfigToContainString added in v0.20.0 

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

WaitForAlertmanagerConfigToContainString retrieves the Alertmanager configuration via the Alertmanager's API and checks if it contains the given string.

func (*Framework) WaitForAlertmanagerInitializedMesh 

func (f *Framework) WaitForAlertmanagerInitializedMesh(ns, name string, amountPeers int) error

func (*Framework) WaitForAlertmanagerReady 

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

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) 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) WaitForTargets 

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

type Target 

type Target struct {
	ScrapeURL string `json:"scrapeUrl"`
}

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) CreateNamespace 

func (ctx *TestCtx) CreateNamespace(t *testing.T, kubeClient kubernetes.Interface) string

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.

func (*TestCtx) SetupPrometheusRBAC 

func (ctx *TestCtx) SetupPrometheusRBAC(t *testing.T, ns string, kubeClient kubernetes.Interface)

func (*TestCtx) SetupPrometheusRBACGlobal added in v0.23.0 

func (ctx *TestCtx) SetupPrometheusRBACGlobal(t *testing.T, ns string, kubeClient kubernetes.Interface)

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.