Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

framework

package

Go to main page

Versions in this module

v0

v0.29.0

Feb 20, 2019

v0.28.0

Jan 29, 2019

v0.27.0

Jan 8, 2019

v0.26.0

Nov 30, 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) DeleteRule(ns string, r string) error

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

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

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

+ func (f *Framework) PrintEvents() error

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

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

type TestCtx

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

v0.25.0

Oct 24, 2018

v0.24.0

Oct 11, 2018

v0.23.2

Aug 23, 2018

v0.23.1

Aug 13, 2018

v0.23.0

Aug 6, 2018

v0.22.2

Jul 24, 2018

v0.22.1

Jul 19, 2018

v0.22.0

Jul 10, 2018

v0.21.0

Jun 28, 2018

v0.20.0

Jun 5, 2018

Changes in this version

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

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

type Framework

+ MonClientV1 monitoringv1.MonitoringV1Interface

+ MonClientV1alpha1 monitoringv1alpha1.MonitoringV1alpha1Interface

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

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

+ func (f *Framework) GetSilences(ns, n string) ([]amAPISil, 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) WaitForPrometheusFiringAlert(ns, svcName, alertName string) error

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

v0.19.0

Apr 27, 2018

v0.18.1

Apr 9, 2018

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

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)

v0.14.1

Nov 1, 2017

v0.14.0

Oct 19, 2017

v0.13.0

Sep 22, 2017

v0.12.0

Aug 24, 2017