increase timeouts due to letsencrypt certs (#254)

* fix terraform workspace remote url path with repo .git * increase timeout waiting for letsencrypt certificates * increase wait for getting the k8s object
konstructio · Dec 4, 2023 · 11f902a · 11f902a
1 parent f76975b
commit 11f902a
Show file tree

Hide file tree

Showing 5 changed files with 22 additions and 36 deletions.
diff --git a/providers/aws/create.go b/providers/aws/create.go
@@ -220,23 +220,23 @@ func CreateAWSCluster(definition *pkgtypes.ClusterDefinition) error {
 		"app.kubernetes.io/instance",
 		"crossplane",
 		"crossplane-system",
-		1200,
+		3600,
 	)
 	if err != nil {
-		log.Errorf("Error finding kubefirst api Deployment: %s", err)
+		log.Errorf("Error finding crossplane Deployment: %s", err)
 		ctrl.HandleError(err.Error())
 		return err
 	}
-	_, err = k8s.WaitForDeploymentReady(kcfg.Clientset, crossplaneDeployment, 300)
+
+	log.Infof("waiting on dns, tls certificates from letsencrypt and remaining sync waves.\n this may take up to 60 minutes but regularly completes in under 20 minutes")
+	_, err = k8s.WaitForDeploymentReady(kcfg.Clientset, crossplaneDeployment, 3600)
 	if err != nil {
 		log.Errorf("Error waiting for all Apps to sync ready state: %s", err)
 
 		ctrl.HandleError(err.Error())
 		return err
 	}
 
-	log.Info("cluster creation complete")
-
 	//* export and import cluster
 	err = ctrl.ExportClusterRecord()
 	if err != nil {
@@ -253,8 +253,6 @@ func CreateAWSCluster(definition *pkgtypes.ClusterDefinition) error {
 			return err
 		}
 
-		log.Info("cluster creation complete")
-
 		telemetry.SendEvent(ctrl.TelemetryEvent, telemetry.ClusterInstallCompleted, "")
 
 		// Create default service entries

diff --git a/providers/civo/create.go b/providers/civo/create.go
@@ -199,19 +199,18 @@ func CreateCivoCluster(definition *pkgtypes.ClusterDefinition) error {
 		1200,
 	)
 	if err != nil {
-		log.Errorf("Error finding kubefirst api Deployment: %s", err)
+		log.Errorf("Error finding crossplane Deployment: %s", err)
 		ctrl.HandleError(err.Error())
 		return err
 	}
-	_, err = k8s.WaitForDeploymentReady(kcfg.Clientset, crossplaneDeployment, 300)
+	log.Infof("waiting on dns, tls certificates from letsencrypt and remaining sync waves.\n this may take up to 60 minutes but regularly completes in under 20 minutes")
+	_, err = k8s.WaitForDeploymentReady(kcfg.Clientset, crossplaneDeployment, 3600)
 	if err != nil {
 		log.Errorf("Error waiting for all Apps to sync ready state: %s", err)
 
 		ctrl.HandleError(err.Error())
 		return err
 	}
-
-	log.Info("cluster creation complete")
 	cluster1KubefirstApiStopChannel := make(chan struct{}, 1)
 	defer func() {
 		close(cluster1KubefirstApiStopChannel)
@@ -234,8 +233,6 @@ func CreateCivoCluster(definition *pkgtypes.ClusterDefinition) error {
 			return err
 		}
 
-		log.Info("cluster creation complete")
-
 		telemetry.SendEvent(ctrl.TelemetryEvent, telemetry.ClusterInstallCompleted, "")
 
 		// Create default service entries
@@ -252,7 +249,7 @@ func CreateCivoCluster(definition *pkgtypes.ClusterDefinition) error {
 		"app.kubernetes.io/name",
 		"kubefirst-api",
 		"kubefirst",
-		1200,
+		3600,
 	)
 	if err != nil {
 		log.Errorf("Error finding kubefirst api Deployment: %s", err)

diff --git a/providers/digitalocean/create.go b/providers/digitalocean/create.go
@@ -193,23 +193,22 @@ func CreateDigitaloceanCluster(definition *pkgtypes.ClusterDefinition) error {
 		"app.kubernetes.io/instance",
 		"crossplane",
 		"crossplane-system",
-		1200,
+		3600,
 	)
 	if err != nil {
-		log.Errorf("Error finding kubefirst api Deployment: %s", err)
+		log.Errorf("Error finding crossplane Deployment: %s", err)
 		ctrl.HandleError(err.Error())
 		return err
 	}
-	_, err = k8s.WaitForDeploymentReady(kcfg.Clientset, crossplaneDeployment, 300)
+	log.Infof("waiting on dns, tls certificates from letsencrypt and remaining sync waves.\n this may take up to 60 minutes but regularly completes in under 20 minutes")
+	_, err = k8s.WaitForDeploymentReady(kcfg.Clientset, crossplaneDeployment, 3600)
 	if err != nil {
 		log.Errorf("Error waiting for all Apps to sync ready state: %s", err)
 
 		ctrl.HandleError(err.Error())
 		return err
 	}
 
-	log.Info("cluster creation complete")
-
 	//* export and import cluster
 	err = ctrl.ExportClusterRecord()
 	if err != nil {
@@ -226,10 +225,7 @@ func CreateDigitaloceanCluster(definition *pkgtypes.ClusterDefinition) error {
 			return err
 		}
 
-		log.Info("cluster creation complete")
-
 		// Telemetry handler
-
 		telemetry.SendEvent(ctrl.TelemetryEvent, telemetry.ClusterInstallCompleted, "")
 
 		// Create default service entries

diff --git a/providers/google/create.go b/providers/google/create.go
@@ -215,23 +215,22 @@ func CreateGoogleCluster(definition *pkgtypes.ClusterDefinition) error {
 		"app.kubernetes.io/instance",
 		"crossplane",
 		"crossplane-system",
-		1200,
+		3600,
 	)
 	if err != nil {
-		log.Errorf("Error finding kubefirst api Deployment: %s", err)
+		log.Errorf("Error finding crossplane Deployment: %s", err)
 		ctrl.HandleError(err.Error())
 		return err
 	}
-	_, err = k8s.WaitForDeploymentReady(kcfg.Clientset, crossplaneDeployment, 300)
+	log.Infof("waiting on dns, tls certificates from letsencrypt and remaining sync waves.\n this may take up to 60 minutes but regularly completes in under 20 minutes")
+	_, err = k8s.WaitForDeploymentReady(kcfg.Clientset, crossplaneDeployment, 3600)
 	if err != nil {
 		log.Errorf("Error waiting for all Apps to sync ready state: %s", err)
 
 		ctrl.HandleError(err.Error())
 		return err
 	}
 
-	log.Info("cluster creation complete")
-
 	cluster1KubefirstApiStopChannel := make(chan struct{}, 1)
 	defer func() {
 		close(cluster1KubefirstApiStopChannel)
@@ -253,8 +252,6 @@ func CreateGoogleCluster(definition *pkgtypes.ClusterDefinition) error {
 			return err
 		}
 
-		log.Info("cluster creation complete")
-
 		telemetry.SendEvent(ctrl.TelemetryEvent, telemetry.ClusterInstallCompleted, "")
 
 		// Create default service entries
@@ -264,7 +261,7 @@ func CreateGoogleCluster(definition *pkgtypes.ClusterDefinition) error {
 			log.Errorf("error adding default service entries for cluster %s: %s", cl.ClusterName, err)
 		}
 	}
-	
+
 	log.Info("waiting for kubefirst-api Deployment to transition to Running")
 	kubefirstAPI, err := k8s.ReturnDeploymentObject(
 		kcfg.Clientset,

diff --git a/providers/vultr/create.go b/providers/vultr/create.go
@@ -192,22 +192,22 @@ func CreateVultrCluster(definition *pkgtypes.ClusterDefinition) error {
 		"app.kubernetes.io/instance",
 		"crossplane",
 		"crossplane-system",
-		1200,
+		3600,
 	)
 	if err != nil {
-		log.Errorf("Error finding kubefirst api Deployment: %s", err)
+		log.Errorf("Error finding crossplane Deployment: %s", err)
 		ctrl.HandleError(err.Error())
 		return err
 	}
-	_, err = k8s.WaitForDeploymentReady(kcfg.Clientset, crossplaneDeployment, 300)
+	log.Infof("waiting on dns, tls certificates from letsencrypt and remaining sync waves.\n this may take up to 60 minutes but regularly completes in under 20 minutes")
+	_, err = k8s.WaitForDeploymentReady(kcfg.Clientset, crossplaneDeployment, 3600)
 	if err != nil {
 		log.Errorf("Error waiting for all Apps to sync ready state: %s", err)
 
 		ctrl.HandleError(err.Error())
 		return err
 	}
 
-
 	//* export and import cluster
 	err = ctrl.ExportClusterRecord()
 	if err != nil {
@@ -224,8 +224,6 @@ func CreateVultrCluster(definition *pkgtypes.ClusterDefinition) error {
 			return err
 		}
 
-		log.Info("cluster creation complete")
-
 		telemetry.SendEvent(ctrl.TelemetryEvent, telemetry.ClusterInstallCompleted, "")
 
 		// Create default service entries