framework

package
v0.10.2 Latest Latest
Warning

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

 Go to latest Published: Jun 21, 2017 License: Apache-2.0 Imports: 28 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 CreateNamespace added in v0.9.0 

func CreateNamespace(kubeClient kubernetes.Interface, name string) (*v1.Namespace, 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) (finalizerFn, 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 DeleteNamespace added in v0.9.0 

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

func DeleteNginxIngressControllerIncDefaultBackend added in v0.8.0 

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

func DeleteServiceAndWaitUntilGone added in v0.9.0 

func DeleteServiceAndWaitUntilGone(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, 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 added in v0.8.0 

func WaitForPodsRunImage(kubeClient kubernetes.Interface, namespace string, expectedReplicas int, image string, opts metav1.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
	DefaultTimeout time.Duration
}

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, ns, 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(ns string, a *v1alpha1.Alertmanager) error

func (*Framework) CreatePrometheusAndWaitUntilReady added in v0.3.0 

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

func (*Framework) DeleteAlertmanagerAndWaitUntilGone added in v0.3.0 

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

func (*Framework) DeletePrometheusAndWaitUntilGone added in v0.3.0 

func (f *Framework) DeletePrometheusAndWaitUntilGone(ns, 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(ns, 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(ns, 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) NewTestCtx added in v0.9.0 

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

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(ns string, a *v1alpha1.Alertmanager) error

func (*Framework) UpdatePrometheusAndWaitUntilReady added in v0.3.0 

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

func (*Framework) WaitForAlertmanagerInitializedMesh added in v0.7.0 

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

func (*Framework) WaitForPrometheusReady added in v0.9.0 

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

func (*Framework) WaitForPrometheusRunImageAndReady added in v0.7.0 

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

func (*Framework) WaitForSpecificAlertmanagerConfig added in v0.7.0 

func (f *Framework) WaitForSpecificAlertmanagerConfig(ns, 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"`
}

type TestCtx added in v0.9.0 

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

func (*TestCtx) AddFinalizerFn added in v0.9.0 

func (ctx *TestCtx) AddFinalizerFn(fn finalizerFn)

func (*TestCtx) Cleanup added in v0.9.0 

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

func (*TestCtx) CreateNamespace added in v0.9.0 

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

func (*TestCtx) GetObjID added in v0.9.0 

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.

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.