Add e2e tests for support to Prometheus by Operator

test/e2e/utils/test_context.go

@@ -27,6 +27,7 @@ import (
 )
 
 const certmanagerVersion = "v0.10.1"
+const prometheusOperatorVersion= "0.33"
 
 // KBTestContext specified to run e2e tests
 type KBTestContext struct {
@@ -94,6 +95,19 @@ func (kc *KBTestContext) InstallCertManager() error {
 	return err
 }
 
+// InstallPrometheusOperManager installs the prometheus manager bundle.
+func (kc *KBTestContext) InstallPrometheusOperManager() error {
+	_, err := kc.Kubectl.Apply(false, "-f", fmt.Sprintf("https://raw.githubusercontent.com/coreos/prometheus-operator/release-%s/bundle.yaml", prometheusOperatorVersion))
+	return err
+}
+
+// UninstallPrometheusOperManager uninstalls the prometheus manager bundle.
+func (kc *KBTestContext) UninstallPrometheusOperManager() {
+	if _, err := kc.Kubectl.Delete(false, "-f", fmt.Sprintf("https://github.com/coreos/prometheus-operator/blob/release-%s/bundle.yaml", prometheusOperatorVersion)); err != nil {
+		fmt.Fprintf(GinkgoWriter, "error when running kubectl delete during cleaning up prometheus bundle: %v\n", err)
+	}
+}
+
 // UninstallCertManager uninstalls the cert manager bundle.
 func (kc *KBTestContext) UninstallCertManager() {
 	if _, err := kc.Kubectl.Delete(false, "-f", fmt.Sprintf("https://github.com/jetstack/cert-manager/releases/download/%s/cert-manager.yaml", certmanagerVersion)); err != nil {

test/e2e/v2/e2e_suite.go

@@ -40,12 +40,18 @@ var _ = Describe("kubebuilder", func() {
 
 			By("installing cert manager bundle")
 			Expect(kbc.InstallCertManager()).To(Succeed())
+
+			By("installing prometheus operator")
+			Expect(kbc.InstallPrometheusOperManager()).To(Succeed())
 		})
 
 		AfterEach(func() {
 			By("clean up created API objects during test process")
 			kbc.CleanupManifests(filepath.Join("config", "default"))
 
+			By("uninstalling prometheus manager bundle")
+			kbc.UninstallPrometheusOperManager()
+
 			By("uninstalling cert manager bundle")
 			kbc.UninstallCertManager()
 
@@ -104,6 +110,9 @@ var _ = Describe("kubebuilder", func() {
 			Expect(utils.UncommentCode(
 				filepath.Join(kbc.Dir, "config", "default", "kustomization.yaml"),
 				"#- ../certmanager", "#")).To(Succeed())
+			Expect(utils.UncommentCode(
+				filepath.Join(kbc.Dir, "config", "default", "kustomization.yaml"),
+				"#- ../prometheus", "#")).To(Succeed())
 			Expect(utils.UncommentCode(
 				filepath.Join(kbc.Dir, "config", "default", "kustomization.yaml"),
 				"#- manager_webhook_patch.yaml", "#")).To(Succeed())
@@ -189,6 +198,20 @@ var _ = Describe("kubebuilder", func() {
 				return err
 			}, time.Minute, time.Second).Should(Succeed())
 
+			By("validate prometheus manager has provisioned the Service")
+			Eventually(func() error {
+				_, err := kbc.Kubectl.Get(
+					false,
+					"Service", "prometheus-operator")
+				return err
+			}, time.Minute, time.Second).Should(Succeed())
+
+			By("validate Service Monitor for Prometheus is applied in the namespace")
+			_, err = kbc.Kubectl.Get(
+				true,
+				"ServiceMonitor")
+			Expect(err).NotTo(HaveOccurred())
+
 			By("validate the mutating|validating webhooks have the CA injected")
 			verifyCAInjection := func() error {
 				mwhOutput, err := kbc.Kubectl.Get(