kannn
53 lines
1.1 KiB
Go
53 lines
1.1 KiB
Go
package basic
|
|
|
|
import (
|
|
"fmt"
|
|
"time"
|
|
|
|
"github.com/onsi/ginkgo/v2"
|
|
|
|
"kanhole/test/e2e/framework"
|
|
"kanhole/test/e2e/framework/consts"
|
|
"kanhole/test/e2e/pkg/port"
|
|
"kanhole/test/e2e/pkg/request"
|
|
)
|
|
|
|
var _ = ginkgo.Describe("[Feature: XTCP]", func() {
|
|
f := framework.NewDefaultFramework()
|
|
|
|
ginkgo.It("Fallback To STCP", func() {
|
|
serverConf := consts.LegacyDefaultServerConfig
|
|
clientConf := consts.LegacyDefaultClientConfig
|
|
|
|
bindPortName := port.GenName("XTCP")
|
|
clientConf += fmt.Sprintf(`
|
|
[foo]
|
|
type = stcp
|
|
local_port = {{ .%s }}
|
|
|
|
[foo-visitor]
|
|
type = stcp
|
|
role = visitor
|
|
server_name = foo
|
|
bind_port = -1
|
|
|
|
[bar-visitor]
|
|
type = xtcp
|
|
role = visitor
|
|
server_name = bar
|
|
bind_port = {{ .%s }}
|
|
keep_tunnel_open = true
|
|
fallback_to = foo-visitor
|
|
fallback_timeout_ms = 200
|
|
`, framework.TCPEchoServerPort, bindPortName)
|
|
|
|
f.RunProcesses(serverConf, []string{clientConf})
|
|
framework.NewRequestExpect(f).
|
|
RequestModify(func(r *request.Request) {
|
|
r.Timeout(time.Second)
|
|
}).
|
|
PortName(bindPortName).
|
|
Ensure()
|
|
})
|
|
})
|