jiazhizhong/higress
1
0
Fork 0
mirror of https://github.com/alibaba/higress.git synced 2026-05-27 22:27:29 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix UT (#24)

Browse Source
This commit is contained in:
澄潭
2022-11-04 12:58:21 +08:00
committed by GitHub
parent 75a961f0ac
commit 0a6274f658
3 changed files with 12 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
ingress/kube/annotations/retry_test.go
View File

@@ -19,6 +19,7 @@ import (
"testing" "testing"
"github.com/gogo/protobuf/types" "github.com/gogo/protobuf/types"
"github.com/stretchr/testify/assert"
networking "istio.io/api/networking/v1alpha3" networking "istio.io/api/networking/v1alpha3"
) )
@@ -100,9 +101,7 @@ func TestRetryParse(t *testing.T) {
t.Run("", func(t *testing.T) { t.Run("", func(t *testing.T) {
config := &Ingress{} config := &Ingress{}
_ = retry.Parse(inputCase.input, config, nil) _ = retry.Parse(inputCase.input, config, nil)
if !reflect.DeepEqual(inputCase.expect, config.Retry) { assert.Equal(t, inputCase.expect, config.Retry)
t.Fatalf("Should be equal")
}
}) })
} }
} }

10
ingress/kube/ingress/controller.go
View File

@@ -379,15 +379,15 @@ func (c *controller) ConvertGateway(convertOptions *common.ConvertOptions, wrapp
preDomainBuilder, _ := convertOptions.IngressDomainCache.Valid[rule.Host] preDomainBuilder, _ := convertOptions.IngressDomainCache.Valid[rule.Host]
if !exist { if !exist {
wrapperGateway = &common.WrapperGateway{ wrapperGateway = &common.WrapperGateway{
Gateway: &networking.Gateway{ Gateway: &networking.Gateway{},
Selector: map[string]string{
c.options.GatewaySelectorKey: c.options.GatewaySelectorValue,
},
},
WrapperConfig: wrapper, WrapperConfig: wrapper,
ClusterId: c.options.ClusterId, ClusterId: c.options.ClusterId,
Host: rule.Host, Host: rule.Host,
} }
if c.options.GatewaySelectorKey != "" {
wrapperGateway.Gateway.Selector = map[string]string{c.options.GatewaySelectorKey: c.options.GatewaySelectorValue}
}
wrapperGateway.Gateway.Servers = append(wrapperGateway.Gateway.Servers, &networking.Server{ wrapperGateway.Gateway.Servers = append(wrapperGateway.Gateway.Servers, &networking.Server{
Port: &networking.Port{ Port: &networking.Port{
Number: 80, Number: 80,

10
ingress/kube/ingressv1/controller.go
View File

@@ -373,15 +373,15 @@ func (c *controller) ConvertGateway(convertOptions *common.ConvertOptions, wrapp
preDomainBuilder, _ := convertOptions.IngressDomainCache.Valid[rule.Host] preDomainBuilder, _ := convertOptions.IngressDomainCache.Valid[rule.Host]
if !exist { if !exist {
wrapperGateway = &common.WrapperGateway{ wrapperGateway = &common.WrapperGateway{
Gateway: &networking.Gateway{ Gateway: &networking.Gateway{},
Selector: map[string]string{
c.options.GatewaySelectorKey: c.options.GatewaySelectorValue,
},
},
WrapperConfig: wrapper, WrapperConfig: wrapper,
ClusterId: c.options.ClusterId, ClusterId: c.options.ClusterId,
Host: rule.Host, Host: rule.Host,
} }
if c.options.GatewaySelectorKey != "" {
wrapperGateway.Gateway.Selector = map[string]string{c.options.GatewaySelectorKey: c.options.GatewaySelectorValue}
}
wrapperGateway.Gateway.Servers = append(wrapperGateway.Gateway.Servers, &networking.Server{ wrapperGateway.Gateway.Servers = append(wrapperGateway.Gateway.Servers, &networking.Server{
Port: &networking.Port{ Port: &networking.Port{
Number: 80, Number: 80,