test(e2e): parallelise test execution

Signed-off-by: Francesco Canovai <[email protected]>

Author: fcanovai

Taskfile.yml

@@ -204,7 +204,17 @@ tasks:
     deps:
       - build-images
     cmds:
-      - go test -timeout 60m -v ./test/e2e
+      - >
+        go run github.com/onsi/ginkgo/v2/ginkgo
+        --procs=8
+        --randomize-all
+        --randomize-suites
+        --fail-on-pending
+        --fail-on-empty
+        --keep-going
+        --timeout=30m
+        --github-output
+        ./test/e2e
 
   ci:
     desc: Run the CI pipeline

test/e2e/e2e_suite_test.go

@@ -22,20 +22,12 @@ import (
 	"testing"
 	"time"
 
-	certmanagerv1 "github.com/cert-manager/cert-manager/pkg/apis/certmanager/v1"
-	cloudnativepgv1 "github.com/cloudnative-pg/api/pkg/api/v1"
-	admissionregistrationv1 "k8s.io/api/admissionregistration/v1"
-	appsv1 "k8s.io/api/apps/v1"
-	corev1 "k8s.io/api/core/v1"
-	rbacv1 "k8s.io/api/rbac/v1"
-	apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1"
 	apimachineryTypes "k8s.io/apimachinery/pkg/types"
 	"k8s.io/apimachinery/pkg/util/wait"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 	kustomizeTypes "sigs.k8s.io/kustomize/api/types"
 	"sigs.k8s.io/kustomize/kyaml/resid"
 
-	pluginBarmanCloudV1 "github.com/cloudnative-pg/plugin-barman-cloud/api/v1"
 	"github.com/cloudnative-pg/plugin-barman-cloud/test/e2e/internal/deployment"
 	"github.com/cloudnative-pg/plugin-barman-cloud/test/e2e/internal/e2etestenv"
 	"github.com/cloudnative-pg/plugin-barman-cloud/test/e2e/internal/kustomize"
@@ -96,32 +88,6 @@ var _ = SynchronizedBeforeSuite(func(ctx SpecContext) []byte {
 		},
 	}
 
-	scheme := cl.Scheme()
-	if err := corev1.AddToScheme(scheme); err != nil {
-		Fail(fmt.Sprintf("failed to add core/v1 to scheme: %v", err))
-	}
-	if err := apiextensionsv1.AddToScheme(scheme); err != nil {
-		Fail(fmt.Sprintf("failed to add apiextensions/v1 to scheme: %v", err))
-	}
-	if err := admissionregistrationv1.AddToScheme(scheme); err != nil {
-		Fail(fmt.Sprintf("failed to add admissionregistration/v1 to scheme: %v", err))
-	}
-	if err := rbacv1.AddToScheme(scheme); err != nil {
-		Fail(fmt.Sprintf("failed to add rbac/v1 to scheme: %v", err))
-	}
-	if err := appsv1.AddToScheme(scheme); err != nil {
-		Fail(fmt.Sprintf("failed to add apps/v1 to scheme: %v", err))
-	}
-	if err := certmanagerv1.AddToScheme(scheme); err != nil {
-		Fail(fmt.Sprintf("failed to add cert-manager.io/v1 to scheme: %v", err))
-	}
-	if err := pluginBarmanCloudV1.AddToScheme(scheme); err != nil {
-		Fail(fmt.Sprintf("failed to add plugin-barman-cloud/v1 to scheme: %v", err))
-	}
-	if err := cloudnativepgv1.AddToScheme(scheme); err != nil {
-		Fail(fmt.Sprintf("failed to add postgresql.cnpg.io/v1 to scheme: %v", err))
-	}
-
 	if err := kustomize.ApplyKustomization(ctx, cl, barmanCloudKustomization); err != nil {
 		Fail(fmt.Sprintf("failed to apply kustomization: %v", err))
 	}

test/e2e/internal/client/client.go

@@ -19,10 +19,19 @@ package client
 import (
 	"fmt"
 
+	certmanagerv1 "github.com/cert-manager/cert-manager/pkg/apis/certmanager/v1"
+	cloudnativepgv1 "github.com/cloudnative-pg/api/pkg/api/v1"
+	admissionregistrationv1 "k8s.io/api/admissionregistration/v1"
+	appsv1 "k8s.io/api/apps/v1"
+	corev1 "k8s.io/api/core/v1"
+	rbacv1 "k8s.io/api/rbac/v1"
+	apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1"
 	"k8s.io/client-go/kubernetes"
 	"k8s.io/client-go/rest"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 	"sigs.k8s.io/controller-runtime/pkg/client/config"
+
+	pluginBarmanCloudV1 "github.com/cloudnative-pg/plugin-barman-cloud/api/v1"
 )
 
 // NewClient creates a new controller-runtime Kubernetes client.
@@ -38,6 +47,10 @@ func NewClient() (client.Client, *rest.Config, error) {
 		return nil, nil, fmt.Errorf("failed to create Kubernetes client: %w", err)
 	}
 
+	if err := addScheme(cl); err != nil {
+		return nil, nil, fmt.Errorf("failed to add scheme: %w", err)
+	}
+
 	return cl, cfg, nil
 }
 
@@ -54,3 +67,33 @@ func NewClientSet() (*kubernetes.Clientset, *rest.Config, error) {
 
 	return clientSet, cfg, nil
 }
+
+func addScheme(cl client.Client) error {
+	scheme := cl.Scheme()
+	if err := corev1.AddToScheme(scheme); err != nil {
+		return fmt.Errorf("failed to add core/v1 to scheme: %w", err)
+	}
+	if err := apiextensionsv1.AddToScheme(scheme); err != nil {
+		return fmt.Errorf("failed to add apiextensions/v1 to scheme: %w", err)
+	}
+	if err := admissionregistrationv1.AddToScheme(scheme); err != nil {
+		return fmt.Errorf("failed to add admissionregistration/v1 to scheme: %w", err)
+	}
+	if err := rbacv1.AddToScheme(scheme); err != nil {
+		return fmt.Errorf("failed to add rbac/v1 to scheme: %w", err)
+	}
+	if err := appsv1.AddToScheme(scheme); err != nil {
+		return fmt.Errorf("failed to add apps/v1 to scheme: %w", err)
+	}
+	if err := certmanagerv1.AddToScheme(scheme); err != nil {
+		return fmt.Errorf("failed to add cert-manager/v1 to scheme: %w", err)
+	}
+	if err := pluginBarmanCloudV1.AddToScheme(scheme); err != nil {
+		return fmt.Errorf("failed to add plugin-barman-cloud/v1 to scheme: %w", err)
+	}
+	if err := cloudnativepgv1.AddToScheme(scheme); err != nil {
+		return fmt.Errorf("failed to add cloudnativepg/v1 to scheme: %w", err)
+	}
+
+	return nil
+}