framework

package
v0.8.0 Latest Latest
Warning

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

 Go to latest Published: Apr 7, 2017 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func CreateAndWaitForThirdPartyRessource added in v0.8.0 

func CreateAndWaitForThirdPartyRessource(kubeClient kubernetes.Interface, relativePath string, apiPath string) error

func CreateClusterRole added in v0.8.0 

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

func CreateClusterRoleBinding added in v0.8.0 

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

func CreateDeployment added in v0.8.0 

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

func CreateIngress added in v0.8.0 

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

func CreateServiceAccount added in v0.8.0 

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

func CreateServiceAndWaitUntilReady added in v0.8.0 

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

func DeleteClusterRole added in v0.8.0 

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

func DeleteClusterRoleBinding added in v0.8.0 

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

func DeleteDeployment added in v0.8.0 

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

func DeleteNginxIngressControllerIncDefaultBackend added in v0.8.0 

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

func DeleteService added in v0.8.0 

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

func DeleteThirdPartyResource added in v0.8.0 

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

func GetIngressIP added in v0.8.0 

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

func GetLogs added in v0.8.0 

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

func MakeBasicIngress added in v0.8.0 

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

func MakeDeployment added in v0.8.0 

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

func PathToOSFile added in v0.8.0 

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

func ProxyGetPod added in v0.8.0 

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

func SetupNginxIngressControllerIncDefaultBackend added in v0.8.0 

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

func WaitForHTTPSuccessStatusCode added in v0.8.0 

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

func WaitForPodsReady added in v0.8.0 

func WaitForPodsReady(kubeClient kubernetes.Interface, namespace string, expectedReplicas int, opts v1.ListOptions) error

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

func WaitForPodsRunImage added in v0.8.0 

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

func WaitForServiceReady added in v0.8.0 

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

func WaitForThridPartyRessource added in v0.8.0 

func WaitForThridPartyRessource(kubeClient kubernetes.Interface, apiPath string) error

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 added in v0.3.0 

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

func (*Framework) AlertmanagerConfigSecret added in v0.7.0 

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

func (*Framework) CreateAlertmanagerAndWaitUntilReady added in v0.3.0 

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

func (*Framework) CreatePrometheusAndWaitUntilReady added in v0.3.0 

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

func (*Framework) DeleteAlertmanagerAndWaitUntilGone added in v0.3.0 

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

func (*Framework) DeletePrometheusAndWaitUntilGone added in v0.3.0 

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

func (*Framework) GetActiveTargets added in v0.6.0 

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

func (*Framework) GetAlertmanagerConfig added in v0.7.0 

func (f *Framework) GetAlertmanagerConfig(n string) (alertmanagerStatus, error)

func (*Framework) MakeAlertmanagerNodePortService added in v0.5.0 

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

func (*Framework) MakeAlertmanagerService added in v0.3.0 

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

func (*Framework) MakeBasicAlertmanager added in v0.3.0 

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

func (*Framework) MakeBasicPrometheus added in v0.3.0 

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

func (*Framework) MakeBasicPrometheusNodePortService added in v0.5.0 

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

func (*Framework) MakeBasicServiceMonitor added in v0.3.0 

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

func (*Framework) MakePrometheusService added in v0.3.0 

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

func (*Framework) Poll added in v0.5.0 

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

func (*Framework) SecretFromYaml added in v0.7.0 

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

func (*Framework) Teardown 

func (f *Framework) Teardown() error

Teardown tears down a previously initialized test environment.

func (*Framework) UpdateAlertmanagerAndWaitUntilReady added in v0.3.0 

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

func (*Framework) UpdatePrometheusAndWaitUntilReady added in v0.3.0 

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

func (*Framework) WaitForAlertmanagerInitializedMesh added in v0.7.0 

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

func (*Framework) WaitForPrometheusRunImageAndReady added in v0.7.0 

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

func (*Framework) WaitForSpecificAlertmanagerConfig added in v0.7.0 

func (f *Framework) WaitForSpecificAlertmanagerConfig(amName string, expectedConfig string) error

func (*Framework) WaitForTargets added in v0.6.0 

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

type Target added in v0.6.0 

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

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.