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

Merge pull request #1707 from MaxRink/fix/ipv6-cp-vip-e2e-timeout

Browse Source 
test(e2e): raise IPv6 control-plane VIP reachability timeout for parallel runs
This commit is contained in:
Daniel Finneran
2026-09-02 17:24:42 +01:00
committed by GitHub
parent a36dc36947 0e57deef3d
commit a51944b89d
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)
}
}