test: lb creation timeouts depending on test case

Author: lukasmetzner

tests/e2e/cloud_test.go

@@ -73,7 +73,7 @@ func TestServiceLoadBalancersMinimalSetup(t *testing.T) {
 		string(annotation.LBLocation): "nbg1",
 	})
 
-	lbSvc, err = lbTest.CreateService(lbSvc)
+	lbSvc, err = lbTest.CreateService(lbSvc, 6*time.Minute)
 	require.NoError(t, err)
 
 	err = lbTest.WaitForHTTPAvailable(lbSvc.Status.LoadBalancer.Ingress[0].IP, false)
@@ -102,7 +102,7 @@ func TestServiceLoadBalancersHTTPS(t *testing.T) {
 		string(annotation.LBSvcProtocol):         "https",
 	})
 
-	lbSvc, err = lbTest.CreateService(lbSvc)
+	lbSvc, err = lbTest.CreateService(lbSvc, 6*time.Minute)
 	require.NoError(t, err)
 
 	err = lbTest.WaitForHTTPAvailable(lbSvc.Status.LoadBalancer.Ingress[0].IP, true)
@@ -135,7 +135,7 @@ func TestServiceLoadBalancersHTTPSWithManagedCertificate(t *testing.T) {
 		string(annotation.LBSvcHTTPManagedCertificateUseACMEStaging): "true",
 	})
 
-	lbSvc, err = lbTest.CreateService(lbSvc)
+	lbSvc, err = lbTest.CreateService(lbSvc, 16*time.Minute)
 	require.NoError(t, err)
 
 	certs, err := testCluster.hcloud.Certificate.AllWithOpts(t.Context(), hcloud.CertificateListOpts{
@@ -171,7 +171,7 @@ func TestServiceLoadBalancersWithPrivateNetwork(t *testing.T) {
 		string(annotation.PrivateSubnetIPRange): ipRange.String(),
 	})
 
-	lbSvc, err = lbTest.CreateService(lbSvc)
+	lbSvc, err = lbTest.CreateService(lbSvc, 8*time.Minute)
 	require.NoError(t, err)
 
 	err = lbTest.WaitForHTTPAvailable(lbSvc.Status.LoadBalancer.Ingress[0].IP, false)

tests/e2e/helper_test.go

@@ -292,7 +292,7 @@ func (l *lbTestHelper) ServiceDefinition(pod *corev1.Pod, annotations map[string
 
 // CreateService creates a k8s service based on the given service definition
 // and waits until it is "ready".
-func (l *lbTestHelper) CreateService(lbSvc *corev1.Service) (*corev1.Service, error) {
+func (l *lbTestHelper) CreateService(lbSvc *corev1.Service, timeout time.Duration) (*corev1.Service, error) {
 	l.t.Helper()
 
 	lbSvc, err := testCluster.k8sClient.CoreV1().Services(l.namespace).Create(l.t.Context(), lbSvc, metav1.CreateOptions{})
@@ -302,7 +302,7 @@ func (l *lbTestHelper) CreateService(lbSvc *corev1.Service) (*corev1.Service, er
 
 	testCluster.loadBalancers.Add(string(lbSvc.UID))
 
-	ctx, cancel := context.WithTimeout(l.t.Context(), 8*time.Minute)
+	ctx, cancel := context.WithTimeout(l.t.Context(), timeout)
 	defer cancel()
 
 	retries := 0