framework

Feb 20, 2019

Changes in this version

type Framework

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

Oct 11, 2018

Changes in this version

type Framework

+ func (f *Framework) CheckPrometheusFiringAlert(ns, svcName, alertName string) (bool, error)

+ func (f *Framework) CreatePrometheusOperator(ns, opImage string, namespacesToWatch []string) error

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

+ func (f *Framework) SendAlertToAlertmanager(ns, n string, start time.Time) error

Aug 6, 2018

Changes in this version

type Framework

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

type TestCtx

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

Jul 10, 2018

Changes in this version

type Framework

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

+ func (f *Framework) PrintEvents() error

+ func (f *Framework) PrintPodLogs(ns, p string) error

Jun 28, 2018

Changes in this version

type Framework

+ func (f *Framework) MakeThanosQuerierService(name string) *v1.Service

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

Jun 5, 2018

Changes in this version

type Framework

+ MonClientV1 monitoringv1.MonitoringV1Interface

+ MonClientV1alpha1 monitoringv1alpha1.MonitoringV1alpha1Interface

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

+ func (f *Framework) MakeAndCreateFiringRule(ns, name, alertName string) (monitoringv1.PrometheusRule, error)

+ func (f *Framework) MakeBasicRule(ns, name string, groups []monitoringv1.RuleGroup) monitoringv1.PrometheusRule

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

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

+ func (f *Framework) WaitForConfigMapExist(ns, name string) (*v1.ConfigMap, error)

+ func (f *Framework) WaitForConfigMapNotExist(ns, name string) error

+ func (f *Framework) WaitForRule(ns, name string) error

Apr 27, 2018

Changes in this version

+ func AddLabelsToNamespace(kubeClient kubernetes.Interface, name string, ...) error

type Framework

+ func (f *Framework) WaitForPrometheusFiringAlert(ns, svcName, alertName string) error

Apr 9, 2018

Changes in this version

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

type Framework

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

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

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)