Make integration tests parallel

Author: Zerpet

Makefile

@@ -83,7 +83,7 @@ integration-tests::just-integration-tests ## Run integration tests
 
 .PHONY: just-integration-tests
 just-integration-tests:
-	$(GINKGO) -r controllers/
+	$(GINKGO) -r -p controllers/
 
 manifests: install-tools ## Generate manifests e.g. CRD, RBAC etc.
 	controller-gen crd rbac:roleName=operator-role paths="./api/...;./controllers/..." output:crd:artifacts:config=config/crd/bases

controllers/rabbitmqcluster_controller_test.go

@@ -488,8 +488,12 @@ var _ = Describe("RabbitmqClusterController", func() {
 			Expect(resourceRequirements.Limits).To(HaveKeyWithValue(corev1.ResourceMemory, expectedRequirements.Limits[corev1.ResourceMemory]))
 
 			// verify that SuccessfulUpdate event is recorded for the StatefulSet
-			Expect(aggregateEventMsgs(ctx, cluster, "SuccessfulUpdate")).To(
-				ContainSubstring("updated resource %s of Type *v1.StatefulSet", cluster.ChildResourceName("server")))
+			Eventually(func() string {
+				return aggregateEventMsgs(ctx, cluster, "SuccessfulUpdate")
+			}).
+				Within(5 * time.Second).
+				WithPolling(time.Second).
+				Should(ContainSubstring("updated resource %s of Type *v1.StatefulSet", cluster.ChildResourceName("server")))
 		})
 
 		It("the rabbitmq image is updated", func() {

controllers/suite_test.go

@@ -12,6 +12,7 @@ package controllers_test
 
 import (
 	"context"
+	"fmt"
 	"path/filepath"
 	"testing"
 
@@ -73,6 +74,9 @@ var _ = BeforeSuite(func() {
 	By("bootstrapping test environment")
 	testEnv = &envtest.Environment{
 		CRDDirectoryPaths: []string{filepath.Join("..", "config", "crd", "bases")},
+		Config: &rest.Config{
+			Host: fmt.Sprintf("http://localhost:218%d", GinkgoParallelProcess()),
+		},
 	}
 
 	cfg, err := testEnv.Start()