framework

package

Go to main page

Versions in this module

v0

v0.20.0

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

v0.19.0

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

v0.18.1

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)

v0.18.0

Apr 4, 2018

v0.17.0

Feb 15, 2018

v0.16.1

Jan 16, 2018

v0.16.0

Jan 12, 2018

v0.15.0

Nov 22, 2017

v0.14.1

Nov 1, 2017

v0.14.0

Oct 19, 2017

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)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL