Merge branch 'master' into tests/e2e-ssl-produce-consume

.github/actions/kind-create/action.yaml

@@ -0,0 +1,47 @@
+name: "Setup kind cluster"
+description: "Creates a kind cluster to be used elsewhere"
+inputs: # adding these parameters to make this reusable later on
+  kind_cluster_name:
+    description: "The kind cluster name to use"
+    required: true
+    default: "e2e-kind"
+  kind_k8s_version:
+    description: 'The k8s version to use'
+    required: true
+    default: 'v1.24.15'
+  kind_config:
+    description: 'Path to the kind config to use'
+    required: true
+    default: 'tests/e2e/platforms/kind/kind_config.yaml'
+outputs:
+  kubeconfig:
+    description: 'Path of the resulting kubeconfig'
+    value: ${{ steps.check-kind-cluster.outputs.kubeconfig }}
+
+runs:
+  using: "composite"
+
+  steps:
+  - name: Set up Docker Buildx
+    uses: docker/setup-buildx-action@v2
+  - uses: engineerd/[email protected]
+    with:
+      name: ${{ inputs.kind_cluster_name }}
+      version: v0.20.0
+      image: kindest/node:${{ inputs.kind_k8s_version }}
+      config: ${{ inputs.kind_config }}
+
+  - name: Check kind cluster and extract kubeconfig
+    id: check-kind-cluster
+    run: |
+      kubectl version
+      kubectl cluster-info
+      kubectl get pods -n kube-system
+      echo "current-context:" $(kubectl config current-context)
+      echo "environment-kubeconfig:" ${KUBECONFIG}
+      mkdir tests/e2e/platforms/kind/${{ inputs.kind_k8s_version }}
+      kubeconfig_path=$(pwd)/tests/e2e/platforms/kind/${{ inputs.kind_k8s_version }}/kind.kconf
+      kind get kubeconfig --name ${{ inputs.kind_cluster_name }} > $kubeconfig_path
+      chmod 600 $kubeconfig_path
+      echo "kubeconfig=$(echo $kubeconfig_path)" >> $GITHUB_OUTPUT
+    shell: bash

.github/workflows/e2e-test.yaml

@@ -0,0 +1,32 @@
+name: e2e-test
+
+on:
+  push:
+    branches:
+      - master
+  pull_request:
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+
+    steps:
+      - name: Set up Go
+        uses: actions/setup-go@v3
+        with:
+          go-version: 1.19
+
+      - name: Checkout code
+        uses: actions/checkout@v3
+
+      - name: Setup Kind cluster
+        id: setup-kind
+        uses: ./.github/actions/kind-create
+
+      - name: run tests
+        env:
+           KUBECONFIG: ${{ steps.setup-kind.outputs.kubeconfig }}
+        run: |
+          go work init
+          go work use -r .
+          make test-e2e

tests/e2e/platforms/kind/kind_config.yaml

@@ -0,0 +1,8 @@
+---
+kind: Cluster
+apiVersion: kind.x-k8s.io/v1alpha4
+nodes:
+  - role: control-plane
+  - role: worker
+  - role: worker
+  - role: worker

tests/e2e/uninstall_cluster.go

@@ -30,7 +30,7 @@ import (
 // checks the removal of the Kafka cluster related resources
 func requireDeleteKafkaCluster(kubectlOptions k8s.KubectlOptions, name string) {
 	It("Delete KafkaCluster custom resource", func() {
-		err := deleteK8sResourceNoErrNotFound(kubectlOptions, defaultDeletionTimeout, kafkaKind, koperatorLocalHelmDescriptor.Namespace)
+		err := deleteK8sResourceNoErrNotFound(kubectlOptions, defaultDeletionTimeout, kafkaKind, name)
 		Expect(err).ShouldNot(HaveOccurred())
 		Eventually(context.Background(), func() []string {
 			By("Verifying the Kafka cluster resource cleanup")