-
Notifications
You must be signed in to change notification settings - Fork 14
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
* fix: add one more step to coordinate with cli * fix: update swag * fix: lint * fix: lint
- Loading branch information
Showing
13 changed files
with
139 additions
and
722 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,106 @@ | ||
| package controller | ||
|
|
||
| import ( | ||
| "fmt" | ||
|
|
||
| "github.com/konstructio/kubefirst-api/internal/constants" | ||
| "github.com/konstructio/kubefirst-api/internal/k8s" | ||
| "github.com/konstructio/kubefirst-api/internal/secrets" | ||
| "github.com/konstructio/kubefirst-api/internal/services" | ||
| log "github.com/rs/zerolog/log" | ||
| ) | ||
|
|
||
| func (clctrl *ClusterController) FinalCheck() error { | ||
| // Wait for last sync wave app transition to Running | ||
| log.Info().Msg("waiting for final sync wave Deployment to transition to Running") | ||
| crossplaneDeployment, err := k8s.ReturnDeploymentObject( | ||
| clctrl.Kcfg.Clientset, | ||
| "app.kubernetes.io/instance", | ||
| "crossplane", | ||
| "crossplane-system", | ||
| 3600, | ||
| ) | ||
| if err != nil { | ||
| clctrl.UpdateClusterOnError(err.Error()) | ||
| return fmt.Errorf("error finding crossplane Deployment: %w", err) | ||
| } | ||
|
|
||
| log.Info().Msg("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(clctrl.Kcfg.Clientset, crossplaneDeployment, 3600) | ||
| if err != nil { | ||
| clctrl.UpdateClusterOnError(err.Error()) | ||
| return fmt.Errorf("error waiting for crossplane deployment to enter Ready state: %w", err) | ||
| } | ||
|
|
||
| // * export and import cluster | ||
| if err := clctrl.ExportClusterRecord(); err != nil { | ||
| log.Error().Msgf("Error exporting cluster record: %s", err) | ||
| return fmt.Errorf("error exporting cluster record: %w", err) | ||
| } | ||
| clctrl.Cluster.Status = constants.ClusterStatusProvisioned | ||
| clctrl.Cluster.InProgress = false | ||
|
|
||
| if err := secrets.UpdateCluster(clctrl.KubernetesClient, clctrl.Cluster); err != nil { | ||
| return fmt.Errorf("error updating cluster status: %w", err) | ||
| } | ||
|
|
||
| log.Info().Msg("cluster creation complete") | ||
|
|
||
| // Create default service entries | ||
| cl, err := secrets.GetCluster(clctrl.KubernetesClient, clctrl.ClusterName) | ||
| if err != nil { | ||
| log.Error().Msgf("error getting cluster %s: %s", clctrl.ClusterName, err) | ||
| clctrl.UpdateClusterOnError(err.Error()) | ||
| return fmt.Errorf("error getting cluster %s: %w", clctrl.ClusterName, err) | ||
| } | ||
|
|
||
| if err := services.AddDefaultServices(cl); err != nil { | ||
| log.Error().Msgf("error adding default service entries for cluster %s: %s", cl.ClusterName, err) | ||
| clctrl.UpdateClusterOnError(err.Error()) | ||
| return fmt.Errorf("error adding default service entries for cluster %s: %w", cl.ClusterName, err) | ||
| } | ||
|
|
||
| if clctrl.InstallKubefirstPro { | ||
| log.Info().Msg("waiting for kubefirst-pro-api Deployment to transition to Running") | ||
| kubefirstProAPI, err := k8s.ReturnDeploymentObject( | ||
| clctrl.Kcfg.Clientset, | ||
| "app.kubernetes.io/name", | ||
| "kubefirst-pro-api", | ||
| "kubefirst", | ||
| 1200, | ||
| ) | ||
| if err != nil { | ||
| clctrl.UpdateClusterOnError(err.Error()) | ||
| return fmt.Errorf("error finding kubefirst-pro-api Deployment: %w", err) | ||
| } | ||
|
|
||
| _, err = k8s.WaitForDeploymentReady(clctrl.Kcfg.Clientset, kubefirstProAPI, 300) | ||
| if err != nil { | ||
| clctrl.UpdateClusterOnError(err.Error()) | ||
| return fmt.Errorf("error waiting for kubefirst-pro-api deployment to enter Ready state: %w", err) | ||
| } | ||
| } | ||
|
|
||
| // Wait for last sync wave app transition to Running | ||
| log.Info().Msg("waiting for final sync wave Deployment to transition to Running") | ||
| argocdDeployment, err := k8s.ReturnDeploymentObject( | ||
| clctrl.Kcfg.Clientset, | ||
| "app.kubernetes.io/name", | ||
| "argocd-server", | ||
| "argocd", | ||
| 3600, | ||
| ) | ||
| if err != nil { | ||
| clctrl.UpdateClusterOnError(err.Error()) | ||
| return fmt.Errorf("error finding argocd Deployment: %w", err) | ||
| } | ||
| _, err = k8s.WaitForDeploymentReady(clctrl.Kcfg.Clientset, argocdDeployment, 3600) | ||
| if err != nil { | ||
| clctrl.UpdateClusterOnError(err.Error()) | ||
| return fmt.Errorf("error waiting for argocd deployment to enter Ready state: %w", err) | ||
| } | ||
|
|
||
| clctrl.Cluster.FinalCheck = true | ||
| log.Info().Msg("cluster creation complete") | ||
| return nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.