fanhuadesenlinnn/kube-vip
1
0
Fork 0
mirror of https://hubproxy.babadafafafafa.cn/https://github.com/kube-vip/kube-vip.git synced 2026-09-20 08:03:47 +08:00
Code Issues Packages Projects Releases Wiki Activity

test(e2e): raise IPv6 control-plane VIP reachability timeout for parallel runs

Browse Source 
The IPv6 control-plane VIP reachability check used a 5s Eventually
window; under the 4-process parallel e2e run on a 4-vCPU runner NDP
convergence for the IPv6 VIP can exceed that, causing intermittent
timeouts while sibling specs pass. Raise it to a load-tolerant window
matching the IPv4 case; the reachability assertion is unchanged.

Signed-off-by: Maximilian Rink <maximilian.rink@telekom.de>
This commit is contained in:
Maximilian Rink
2026-08-23 19:53:06 +02:00
parent b25badd185
commit 0e57deef3d
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
testing/e2e/e2e_test.go
View File

@@ -393,7 +393,7 @@ var _ = Describe("kube-vip ARP/NDP broadcast neighbor", func() {
})
It(clusterName+"provides an IPv6 VIP address for the Kubernetes control plane nodes", func() {
testControlPlaneVIPs(ctx, []string{cpVIP}, clusterName, client)
testControlPlaneVIPsWithTimeout(ctx, []string{cpVIP}, clusterName, client, 2*time.Second, 30*time.Second)
})
})
@@ -1695,6 +1695,11 @@ func cleanupCluster(clusterName, network string, configMtx *sync.Mutex, logger l
}
func testControlPlaneVIPs(ctx context.Context, cpVIPs []string, clusterName string, client kubernetes.Interface) {
testControlPlaneVIPsWithTimeout(ctx, cpVIPs, clusterName, client, time.Duration(0), 20*time.Second)
}
func testControlPlaneVIPsWithTimeout(ctx context.Context, cpVIPs []string, clusterName string, client kubernetes.Interface,
transportTimeout, eventuallyTimeout time.Duration) {
Expect(cpVIPs).ToNot(BeEmpty())
By(withTimestamp("checking that the Kubernetes control plane nodes are accessible via the assigned VIP"))
@@ -1702,7 +1707,7 @@ func testControlPlaneVIPs(ctx context.Context, cpVIPs []string, clusterName stri
// use the default timeout for establishing a connection to the VIP
for _, cpVIP := range cpVIPs {
By(withTimestamp(fmt.Sprintf("testing connection to VIP: %s", cpVIP)))
assertControlPlaneIsRoutable(cpVIP, time.Duration(0), 20*time.Second)
assertControlPlaneIsRoutable(cpVIP, transportTimeout, eventuallyTimeout)
}
var leaderName string
@@ -1720,7 +1725,7 @@ func testControlPlaneVIPs(ctx context.Context, cpVIPs []string, clusterName stri
for _, cpVIP := range cpVIPs {
By(withTimestamp(fmt.Sprintf("testing connection to VIP: %s", cpVIP)))
// Allow at most 30 seconds of downtime when polling the control plane nodes
assertControlPlaneIsRoutable(cpVIP, time.Duration(0), 20*time.Second)
assertControlPlaneIsRoutable(cpVIP, transportTimeout, eventuallyTimeout)
}
}