Versions in this module Expand all Collapse all v0 v0.13.0 Sep 22, 2017 v0.12.0 Aug 24, 2017 Changes in this version + var ValidAlertmanagerConfig = ... + func CreateAndWaitForThirdPartyRessource(kubeClient kubernetes.Interface, relativePath string, apiPath string) error + func CreateClusterRole(kubeClient kubernetes.Interface, relativePath string) error + func CreateClusterRoleBinding(kubeClient kubernetes.Interface, ns string, relativePath string) (finalizerFn, error) + func CreateDeployment(kubeClient kubernetes.Interface, namespace string, d *v1beta1.Deployment) error + func CreateIngress(kubeClient kubernetes.Interface, namespace string, i *v1beta1.Ingress) error + func CreateNamespace(kubeClient kubernetes.Interface, name string) (*v1.Namespace, error) + func CreateRoleBinding(kubeClient kubernetes.Interface, ns string, relativePath string) (finalizerFn, error) + func CreateServiceAccount(kubeClient kubernetes.Interface, namespace string, relativPath string) (finalizerFn, error) + func CreateServiceAndWaitUntilReady(kubeClient kubernetes.Interface, namespace string, service *v1.Service) (finalizerFn, error) + func DeleteClusterRole(kubeClient kubernetes.Interface, relativePath string) error + func DeleteClusterRoleBinding(kubeClient kubernetes.Interface, relativePath string) error + func DeleteDeployment(kubeClient kubernetes.Interface, namespace, name string) error + func DeleteNamespace(kubeClient kubernetes.Interface, name string) error + func DeleteNginxIngressControllerIncDefaultBackend(kubeClient kubernetes.Interface, namespace string) error + func DeleteRoleBinding(kubeClient kubernetes.Interface, ns string, relativePath string) error + func DeleteServiceAccount(kubeClient kubernetes.Interface, namespace string, relativPath string) error + func DeleteServiceAndWaitUntilGone(kubeClient kubernetes.Interface, namespace string, serviceName string) error + func DeleteThirdPartyResource(kubeClient kubernetes.Interface, relativePath string) error + func GetIngressIP(kubeClient kubernetes.Interface, namespace string, ingressName string) (*string, error) + func GetLogs(kubeClient kubernetes.Interface, namespace string, ...) (string, error) + func MakeBasicIngress(serviceName string, servicePort int) *v1beta1.Ingress + func MakeDeployment(pathToYaml string) (*v1beta1.Deployment, error) + func PathToOSFile(relativPath string) (*os.File, error) + func ProxyGetPod(kubeClient kubernetes.Interface, namespace string, podName string, port string, ...) *rest.Request + func SetupNginxIngressControllerIncDefaultBackend(kubeClient kubernetes.Interface, namespace string) error + func WaitForHTTPSuccessStatusCode(timeout time.Duration, url string) error + func WaitForPodsReady(kubeClient kubernetes.Interface, namespace string, timeout time.Duration, ...) error + func WaitForPodsRunImage(kubeClient kubernetes.Interface, namespace string, expectedReplicas int, ...) error + func WaitForServiceReady(kubeClient kubernetes.Interface, namespace string, serviceName string) error + func WaitForThridPartyRessource(kubeClient kubernetes.Interface, apiPath string) error + func WaitUntilDeploymentGone(kubeClient kubernetes.Interface, namespace, name string, timeout time.Duration) error + type Framework struct + DefaultTimeout time.Duration + HTTPClient *http.Client + KubeClient kubernetes.Interface + MasterHost string + MonClient monitoringv1.MonitoringV1Interface + Namespace *v1.Namespace + OperatorPod *v1.Pod + func New(ns, kubeconfig, opImage string) (*Framework, error) + func (f *Framework) AddAlertingToPrometheus(p *monitoringv1.Prometheus, ns, name string) + func (f *Framework) AlertmanagerConfigSecret(name string) (*v1.Secret, error) + func (f *Framework) CreateAlertmanagerAndWaitUntilReady(ns string, a *monitoringv1.Alertmanager) error + func (f *Framework) CreatePrometheusAndWaitUntilReady(ns string, p *monitoringv1.Prometheus) error + func (f *Framework) DeleteAlertmanagerAndWaitUntilGone(ns, name string) error + func (f *Framework) DeletePrometheusAndWaitUntilGone(ns, name string) error + func (f *Framework) GetActiveTargets(ns, svcName string) ([]*Target, error) + func (f *Framework) GetAlertmanagerConfig(ns, n string) (alertmanagerStatus, error) + func (f *Framework) MakeAlertmanagerService(name, group string, serviceType v1.ServiceType) *v1.Service + func (f *Framework) MakeBasicAlertmanager(name string, replicas int32) *monitoringv1.Alertmanager + func (f *Framework) MakeBasicAlertmanagerV1alpha1(name string, replicas int32) *v1alpha1.Alertmanager + func (f *Framework) MakeBasicPrometheus(ns, name, group string, replicas int32) *monitoringv1.Prometheus + func (f *Framework) MakeBasicPrometheusV1alpha1(ns, name, group string, replicas int32) *v1alpha1.Prometheus + func (f *Framework) MakeBasicServiceMonitor(name string) *monitoringv1.ServiceMonitor + func (f *Framework) MakeBasicServiceMonitorV1alpha1(name string) *v1alpha1.ServiceMonitor + func (f *Framework) MakePrometheusService(name, group string, serviceType v1.ServiceType) *v1.Service + func (f *Framework) NewTestCtx(t *testing.T) TestCtx + func (f *Framework) Poll(timeout, pollInterval time.Duration, pollFunc func() (bool, error)) error + func (f *Framework) QueryPrometheusSVC(ns, svcName, endpoint string, query map[string]string) (io.ReadCloser, error) + func (f *Framework) SecretFromYaml(filepath string) (*v1.Secret, error) + func (f *Framework) Setup(opImage string) error + func (f *Framework) Teardown() error + func (f *Framework) UpdateAlertmanagerAndWaitUntilReady(ns string, a *monitoringv1.Alertmanager) error + func (f *Framework) UpdatePrometheusAndWaitUntilReady(ns string, p *monitoringv1.Prometheus) error + func (f *Framework) WaitForAlertmanagerInitializedMesh(ns, name string, amountPeers int) error + func (f *Framework) WaitForAlertmanagerReady(ns, name string, replicas int) error + func (f *Framework) WaitForPrometheusReady(p *monitoringv1.Prometheus, timeout time.Duration) error + func (f *Framework) WaitForPrometheusRunImageAndReady(ns string, p *monitoringv1.Prometheus) error + func (f *Framework) WaitForSpecificAlertmanagerConfig(ns, amName string, expectedConfig string) error + func (f *Framework) WaitForTargets(ns, svcName string, amount int) error + type Target struct + ScrapeURL string + type TestCtx struct + ID string + func (ctx *TestCtx) AddFinalizerFn(fn finalizerFn) + func (ctx *TestCtx) Cleanup(t *testing.T) + func (ctx *TestCtx) CreateNamespace(t *testing.T, kubeClient kubernetes.Interface) string + func (ctx *TestCtx) GetObjID() string + func (ctx *TestCtx) SetupPrometheusRBAC(t *testing.T, ns string, kubeClient kubernetes.Interface)