framework

Documentation

Index

• Variables
• type Framework
  • func New(ns, kubeconfig, opImage, ip string) (*Framework, error)
  • func (f *Framework) AddAlertingToPrometheus(p *v1alpha1.Prometheus, name string)
  • func (f *Framework) CreateAlertmanagerAndWaitUntilReady(a *v1alpha1.Alertmanager) error
  • func (f *Framework) CreateDeployment(kclient kubernetes.Interface, ns string, deploy *v1beta1.Deployment) error
  • func (f *Framework) CreateIngress(i *v1beta1.Ingress) error
  • func (f *Framework) CreatePrometheusAndWaitUntilReady(p *v1alpha1.Prometheus) error
  • func (f *Framework) CreateServiceAndWaitUntilReady(service *v1.Service) error
  • func (f *Framework) DeleteAlertmanagerAndWaitUntilGone(name string) error
  • func (f *Framework) DeleteNginxIngressControllerIncDefaultBackend() error
  • func (f *Framework) DeletePrometheusAndWaitUntilGone(name string) error
  • func (f *Framework) DeleteService(serviceName string) error
  • func (f *Framework) GetActiveTargets() ([]*Target, error)
  • func (f *Framework) GetIngressIP(ingressName string) (*string, error)
  • func (f *Framework) GetLogs(podName, containerName string) (string, error)
  • func (f *Framework) MakeAlertmanagerNodePortService(name, group string, nodePort int32) *v1.Service
  • func (f *Framework) MakeAlertmanagerService(name, group string, serviceType v1.ServiceType) *v1.Service
  • func (f *Framework) MakeBasicAlertmanager(name string, replicas int32) *v1alpha1.Alertmanager
  • func (f *Framework) MakeBasicIngress(serviceName string, servicePort int) *v1beta1.Ingress
  • func (f *Framework) MakeBasicPrometheus(name, group string, replicas int32) *v1alpha1.Prometheus
  • func (f *Framework) MakeBasicPrometheusNodePortService(name, group string, nodePort int32) *v1.Service
  • func (f *Framework) MakeBasicServiceMonitor(name string) *v1alpha1.ServiceMonitor
  • func (f *Framework) MakePrometheusService(name, group string, serviceType v1.ServiceType) *v1.Service
  • func (f *Framework) Poll(timeout, pollInterval time.Duration, pollFunc func() (bool, error)) error
  • func (f *Framework) SetupNginxIngressControllerIncDefaultBackend() error
  • func (f *Framework) Teardown() error
  • func (f *Framework) UpdateAlertmanagerAndWaitUntilReady(a *v1alpha1.Alertmanager) error
  • func (f *Framework) UpdatePrometheusAndWaitUntilReady(p *v1alpha1.Prometheus) error
  • func (f *Framework) WaitForHTTPSuccessStatusCode(timeout time.Duration, url string) error
  • func (f *Framework) WaitForPodsReady(timeout time.Duration, expectedReplicas int, image string, ...) (*v1.PodList, error)
  • func (f *Framework) WaitForServiceReady(serviceName string) error
  • func (f *Framework) WaitForTargets(amount int) error
• type Target

Variables

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

Types

type Framework

type Framework struct {
	KubeClient  kubernetes.Interface
	MonClient   *v1alpha1.MonitoringV1alpha1Client
	HTTPClient  *http.Client
	MasterHost  string
	Namespace   *v1.Namespace
	OperatorPod *v1.Pod
	ClusterIP   string
}

func New

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

Setup setups a test framework and returns it.

func (*Framework) AddAlertingToPrometheus

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

func (*Framework) CreateAlertmanagerAndWaitUntilReady

func (f *Framework) CreateAlertmanagerAndWaitUntilReady(a *v1alpha1.Alertmanager) error

func (*Framework) CreateDeployment

func (f *Framework) CreateDeployment(kclient kubernetes.Interface, ns string, deploy *v1beta1.Deployment) error

func (*Framework) CreateIngress

func (f *Framework) CreateIngress(i *v1beta1.Ingress) error

func (*Framework) CreatePrometheusAndWaitUntilReady

func (f *Framework) CreatePrometheusAndWaitUntilReady(p *v1alpha1.Prometheus) error

func (*Framework) CreateServiceAndWaitUntilReady

func (f *Framework) CreateServiceAndWaitUntilReady(service *v1.Service) error

func (*Framework) DeleteAlertmanagerAndWaitUntilGone

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

func (*Framework) DeleteNginxIngressControllerIncDefaultBackend

func (f *Framework) DeleteNginxIngressControllerIncDefaultBackend() error

func (*Framework) DeletePrometheusAndWaitUntilGone

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

func (*Framework) DeleteService

func (f *Framework) DeleteService(serviceName string) error

func (*Framework) GetActiveTargets

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

func (*Framework) GetIngressIP

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

func (*Framework) GetLogs

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

func (*Framework) MakeAlertmanagerNodePortService

func (f *Framework) MakeAlertmanagerNodePortService(name, group string, nodePort int32) *v1.Service

func (*Framework) MakeAlertmanagerService

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

func (*Framework) MakeBasicAlertmanager

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

func (*Framework) MakeBasicIngress

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

func (*Framework) MakeBasicPrometheus

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

func (*Framework) MakeBasicPrometheusNodePortService

func (f *Framework) MakeBasicPrometheusNodePortService(name, group string, nodePort int32) *v1.Service

func (*Framework) MakeBasicServiceMonitor

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

func (*Framework) MakePrometheusService

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

func (*Framework) Poll

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

func (*Framework) SetupNginxIngressControllerIncDefaultBackend

func (f *Framework) SetupNginxIngressControllerIncDefaultBackend() error

func (*Framework) Teardown

func (f *Framework) Teardown() error

Teardown tears down a previously initialized test environment.

func (*Framework) UpdateAlertmanagerAndWaitUntilReady

func (f *Framework) UpdateAlertmanagerAndWaitUntilReady(a *v1alpha1.Alertmanager) error

func (*Framework) UpdatePrometheusAndWaitUntilReady

func (f *Framework) UpdatePrometheusAndWaitUntilReady(p *v1alpha1.Prometheus) error

func (*Framework) WaitForHTTPSuccessStatusCode

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

func (*Framework) WaitForPodsReady

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

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

func (*Framework) WaitForServiceReady

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

func (*Framework) WaitForTargets

func (f *Framework) WaitForTargets(amount int) error

type Target

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