@@ -24,8 +24,8 @@ import (
2424
2525 . "github.com/onsi/ginkgo/v2"
2626 . "github.com/onsi/gomega"
27- "gopkg.in/yaml.v3"
2827 corev1 "k8s.io/api/core/v1"
28+ "sigs.k8s.io/yaml"
2929
3030 "github.com/apache/apisix-ingress-controller/internal/provider/adc"
3131 "github.com/apache/apisix-ingress-controller/test/e2e/framework"
@@ -66,7 +66,26 @@ metadata:
6666spec:
6767 controllerName: %s
6868`
69- const gatewayProxy = `
69+
70+ var gatewayProxyYaml = `
71+ apiVersion: apisix.apache.org/v1alpha1
72+ kind: GatewayProxy
73+ metadata:
74+ name: apisix-proxy-config
75+ spec:
76+ provider:
77+ type: ControlPlane
78+ controlPlane:
79+ service:
80+ name: %s
81+ port: 9180
82+ auth:
83+ type: AdminKey
84+ adminKey:
85+ value: "%s"
86+ `
87+
88+ var gatewayProxyYamlAPI7 = `
7089apiVersion: apisix.apache.org/v1alpha1
7190kind: GatewayProxy
7291metadata:
@@ -82,6 +101,13 @@ spec:
82101 adminKey:
83102 value: "%s"
84103`
104+ getGatewayProxySpec := func () string {
105+ if s .Deployer .Name () == adc .BackendModeAPI7EE {
106+ return fmt .Sprintf (gatewayProxyYamlAPI7 , s .Deployer .GetAdminEndpoint (), s .AdminKey ())
107+ }
108+ return fmt .Sprintf (gatewayProxyYaml , framework .ProviderType , s .AdminKey ())
109+ }
110+
85111 const defaultGateway = `
86112apiVersion: gateway.networking.k8s.io/v1
87113kind: Gateway
@@ -101,7 +127,7 @@ spec:
101127`
102128 BeforeEach (func () {
103129 By ("create GatewayProxy" )
104- gatewayProxy := fmt . Sprintf ( gatewayProxy , s . Deployer . GetAdminEndpoint (), s . AdminKey () )
130+ gatewayProxy := getGatewayProxySpec ( )
105131 err := s .CreateResourceFromString (gatewayProxy )
106132 Expect (err ).NotTo (HaveOccurred (), "creating GatewayProxy" )
107133 time .Sleep (5 * time .Second )
0 commit comments