github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2026-07-18 04:54:54 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #131064 from aojea/e2e_services_ip

Browse Source 
e2e service ip preservation test
This commit is contained in:
Kubernetes Prow Robot
2025-04-23 15:59:13 -07:00
committed by GitHub
parent ea04d665da 5e4600e46b
commit e63dcda8a2
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
test/e2e/network/service.go
View File

@@ -4036,7 +4036,10 @@ var _ = common.SIGDescribe("Services", func() {
gomega.Expect(thirdNodeIP).NotTo(gomega.Equal(""), "cluster has at least 3 nodes but could not find a third node IP?")
checkOneNodePort := func(nodeIP string, expectResponse bool, trafficPolicy v1.ServiceExternalTrafficPolicy, deadline time.Time) {
cmd := fmt.Sprintf("curl -g -s --connect-timeout 3 http://%s/clientip", net.JoinHostPort(nodeIP, nodePortStr))
// hostExecPod is a hostNetwork Pod, in order to choose the source ip for the connection we need to bind the application or
// "the kernel will choose the first address configured on the interface which falls in the same network as the destination address or the nexthop route"
// Ref: http://linux-ip.net/html/routing-saddr-selection.html
cmd := fmt.Sprintf("curl -g -s --interface %s --connect-timeout 3 http://%s/clientip", hostExecPodNodeIP, net.JoinHostPort(nodeIP, nodePortStr))
var clientIP string
err := wait.PollUntilContextTimeout(ctx, framework.Poll, time.Until(deadline), true, func(ctx context.Context) (bool, error) {
out, err := e2eoutput.RunHostCmd(namespace, execPod.Name, cmd)