fix: add ci

Signed-off-by: ashing <[email protected]>

Author: ronething

.github/workflows/apisix-e2e-test.yml

@@ -0,0 +1,71 @@
+name: APISIX E2E Test
+
+on:
+  push:
+    branches:
+      - master
+      - release-v2-dev
+  pull_request:
+    branches:
+      - master
+      - release-v2-dev
+
+concurrency:
+  group: ${{ github.workflow }}-${{ github.event.pull_request.number || github.ref }}
+  cancel-in-progress: true
+
+jobs:
+  prepare:
+    name: Prepare
+    runs-on: buildjet-2vcpu-ubuntu-2204
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v4
+
+      - name: Setup Go Env
+        id: go
+        uses: actions/setup-go@v4
+        with:
+          go-version: "1.22"
+
+      - name: Install kind
+        run: |
+          go install sigs.k8s.io/[email protected]
+
+  e2e-test:
+    needs: 
+      - prepare
+    runs-on: buildjet-2vcpu-ubuntu-2204
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v4
+        with:
+          submodules: recursive
+
+      - name: Setup Go Env
+        uses: actions/setup-go@v4
+        with:
+          go-version: "1.22"
+
+      - name: Build images
+        env:
+          TAG: dev
+          ARCH: amd64
+          ENABLE_PROXY: "false"
+          BASE_IMAGE_TAG: "debug"
+        run: |
+          echo "building images..."
+          make build-image
+
+      - name: Launch Kind Cluster
+        run: |
+          make kind-up
+
+      - name: Install Gateway API And CRDs
+        run: |
+          make install
+
+      - name: Run E2E test suite
+        shell: bash
+        run: |
+          make e2e-test-standalone

test/e2e/framework/api7_dashboard.go

@@ -23,7 +23,6 @@ import (
 	"text/template"
 
 	"github.com/gavv/httpexpect/v2"
-
 	"github.com/google/uuid"
 	. "github.com/onsi/gomega"
 

test/e2e/framework/api7_framework.go

@@ -8,6 +8,7 @@ import (
 	"time"
 
 	"github.com/api7/gopkg/pkg/log"
+	"github.com/gruntwork-io/terratest/modules/k8s"
 	. "github.com/onsi/ginkgo/v2" //nolint:staticcheck
 	. "github.com/onsi/gomega"    //nolint:staticcheck
 	"github.com/stretchr/testify/assert"
@@ -16,8 +17,6 @@ import (
 	"helm.sh/helm/v3/pkg/chart/loader"
 	"helm.sh/helm/v3/pkg/cli"
 	"helm.sh/helm/v3/pkg/kube"
-
-	"github.com/gruntwork-io/terratest/modules/k8s"
 	k8serrors "k8s.io/apimachinery/pkg/api/errors"
 )
 

test/e2e/framework/k8s.go

@@ -28,7 +28,6 @@ import (
 	"github.com/gavv/httpexpect/v2"
 	"github.com/gruntwork-io/terratest/modules/k8s"
 	"github.com/gruntwork-io/terratest/modules/testing"
-	"github.com/onsi/gomega"
 	. "github.com/onsi/gomega" //nolint:staticcheck
 	"go.uber.org/zap"
 	corev1 "k8s.io/api/core/v1"
@@ -272,7 +271,7 @@ func waitExponentialBackoff(condFunc func() (bool, error)) error {
 
 func (f *Framework) NewExpectResponse(httpBody any) *httpexpect.Response {
 	body, err := json.Marshal(httpBody)
-	f.GomegaT.Expect(err).ShouldNot(gomega.HaveOccurred())
+	f.GomegaT.Expect(err).ShouldNot(HaveOccurred())
 
 	return httpexpect.NewResponse(f.GinkgoT, &http.Response{
 		Header: http.Header{
@@ -287,15 +286,15 @@ func (f *Framework) ListPods(selector string) []corev1.Pod {
 	pods, err := f.clientset.CoreV1().Pods(_namespace).List(context.TODO(), metav1.ListOptions{
 		LabelSelector: selector,
 	})
-	f.GomegaT.Expect(err).ShouldNot(gomega.HaveOccurred(), "list pod: ", selector)
+	f.GomegaT.Expect(err).ShouldNot(HaveOccurred(), "list pod: ", selector)
 	return pods.Items
 }
 
 func (f *Framework) ListRunningPods(selector string) []corev1.Pod {
 	pods, err := f.clientset.CoreV1().Pods(_namespace).List(context.TODO(), metav1.ListOptions{
 		LabelSelector: selector,
 	})
-	f.GomegaT.Expect(err).ShouldNot(gomega.HaveOccurred(), "list pod: ", selector)
+	f.GomegaT.Expect(err).ShouldNot(HaveOccurred(), "list pod: ", selector)
 	runningPods := make([]corev1.Pod, 0)
 	for _, p := range pods.Items {
 		if p.Status.Phase == corev1.PodRunning && p.DeletionTimestamp == nil {
@@ -324,7 +323,7 @@ func (f *Framework) ExecCommandInPod(podName string, cmd ...string) (string, str
 
 	var stdout, stderr bytes.Buffer
 	exec, err := remotecommand.NewSPDYExecutor(f.restConfig, "POST", req.URL())
-	f.GomegaT.Expect(err).ShouldNot(gomega.HaveOccurred(), "request kubernetes exec api")
+	f.GomegaT.Expect(err).ShouldNot(HaveOccurred(), "request kubernetes exec api")
 	_ = exec.StreamWithContext(context.TODO(), remotecommand.StreamOptions{
 		Stdin:  nil,
 		Stdout: &stdout,
@@ -338,13 +337,13 @@ func (f *Framework) GetPodLogs(name string, previous bool) string {
 		Pods(_namespace).
 		GetLogs(name, &corev1.PodLogOptions{Previous: previous}).
 		Stream(context.Background())
-	f.GomegaT.Expect(err).ShouldNot(gomega.HaveOccurred(), "get logs")
+	f.GomegaT.Expect(err).ShouldNot(HaveOccurred(), "get logs")
 	defer func() {
 		_ = reader.Close()
 	}()
 
 	logs, err := io.ReadAll(reader)
-	f.GomegaT.Expect(err).ShouldNot(gomega.HaveOccurred(), "read all logs")
+	f.GomegaT.Expect(err).ShouldNot(HaveOccurred(), "read all logs")
 
 	return string(logs)
 }
@@ -367,7 +366,7 @@ func (f *Framework) WaitPodsLog(selector, keyword string, sinceSeconds int64, ti
 				opts.TailLines = ptr.To(int64(0))
 			}
 			logStream, err := f.clientset.CoreV1().Pods(p.Namespace).GetLogs(p.Name, &opts).Stream(context.Background())
-			f.GomegaT.Expect(err).Should(gomega.BeNil())
+			f.GomegaT.Expect(err).Should(BeNil())
 			scanner := bufio.NewScanner(logStream)
 			scanner.Split(bufio.ScanLines)
 			for scanner.Scan() {

test/e2e/scaffold/apisix_deployer.go

@@ -6,14 +6,14 @@ import (
 	"os"
 	"time"
 
-	"github.com/apache/apisix-ingress-controller/pkg/utils"
-	"github.com/apache/apisix-ingress-controller/test/e2e/framework"
 	"github.com/gruntwork-io/terratest/modules/k8s"
 	. "github.com/onsi/ginkgo/v2" //nolint:staticcheck
 	. "github.com/onsi/gomega"    //nolint:staticcheck
-
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+
+	"github.com/apache/apisix-ingress-controller/pkg/utils"
+	"github.com/apache/apisix-ingress-controller/test/e2e/framework"
 )
 
 type APISIXDeployOptions struct {
@@ -199,6 +199,7 @@ func getEnvOrDefault(key, defaultValue string) string {
 	return defaultValue
 }
 
+//nolint:unused
 func (s *APISIXDeployer) createAdminTunnel(
 	svc *corev1.Service,
 	kubectlOpts *k8s.KubectlOptions,