-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Signed-off-by: Dipankar Das <[email protected]>
- Loading branch information
1 parent
7c14048
commit 9b18bf2
Showing
8 changed files
with
270 additions
and
14 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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,72 @@ | ||
| package cmd | ||
|
|
||
| // authors Dipankar <[email protected]> | ||
|
|
||
| import ( | ||
| "context" | ||
| "os" | ||
|
|
||
| "github.com/ksctl/ksctl/pkg/helpers" | ||
|
|
||
| "github.com/spf13/cobra" | ||
|
|
||
| "github.com/ksctl/ksctl/pkg/helpers/consts" | ||
| ) | ||
|
|
||
| var addMoreWorkerNodesHAAws = &cobra.Command{ | ||
| Use: "add-nodes", | ||
| Short: "Use to add more worker nodes in HA aws k3s cluster", | ||
| Long: `It is used to add nodes to worker nodes in cluster with the given name from user. For example: | ||
| ksctl create-cluster ha-azure add-nodes <arguments to civo cloud provider> | ||
| `, | ||
| Run: func(cmd *cobra.Command, args []string) { | ||
| verbosity, _ := cmd.Flags().GetInt("verbose") | ||
| SetRequiredFeatureFlags(cmd) | ||
|
|
||
| cli.Client.Metadata.LogVerbosity = verbosity | ||
| cli.Client.Metadata.LogWritter = os.Stdout | ||
| cli.Client.Metadata.Provider = consts.CloudAws | ||
|
|
||
| SetDefaults(consts.CloudAws, consts.ClusterTypeHa) | ||
|
|
||
| cli.Client.Metadata.NoWP = noWP | ||
| cli.Client.Metadata.WorkerPlaneNodeType = nodeSizeWP | ||
| cli.Client.Metadata.ClusterName = clusterName | ||
| cli.Client.Metadata.Region = region | ||
| cli.Client.Metadata.IsHA = true | ||
| cli.Client.Metadata.K8sDistro = consts.KsctlKubernetes(distro) | ||
| cli.Client.Metadata.K8sVersion = k8sVer | ||
|
|
||
| if err := safeInitializeStorageLoggerFactory(context.WithValue(context.Background(), "USERID", helpers.GetUserName())); err != nil { | ||
| log.Error("Failed Initialize Storage Driver", "Reason", err) | ||
| os.Exit(1) | ||
| } | ||
|
|
||
| if err := createApproval(cmd.Flags().Lookup("approve").Changed); err != nil { | ||
| log.Error(err.Error()) | ||
| os.Exit(1) | ||
| } | ||
|
|
||
| err := controller.AddWorkerPlaneNode(&cli.Client) | ||
| if err != nil { | ||
| log.Error("Failed to scale up", "Reason", err) | ||
| os.Exit(1) | ||
| } | ||
| log.Success("Scale up successful") | ||
| }, | ||
| } | ||
|
|
||
| func init() { | ||
| createClusterHAAws.AddCommand(addMoreWorkerNodesHAAws) | ||
| clusterNameFlag(addMoreWorkerNodesHAAws) | ||
| noOfWPFlag(addMoreWorkerNodesHAAws) | ||
| nodeSizeWPFlag(addMoreWorkerNodesHAAws) | ||
| regionFlag(addMoreWorkerNodesHAAws) | ||
| k8sVerFlag(addMoreWorkerNodesHAAws) | ||
| distroFlag(addMoreWorkerNodesHAAws) | ||
| storageFlag(addMoreWorkerNodesHAAws) | ||
|
|
||
| addMoreWorkerNodesHAAws.MarkFlagRequired("name") | ||
| addMoreWorkerNodesHAAws.MarkFlagRequired("region") | ||
| } |
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,68 @@ | ||
| package cmd | ||
|
|
||
| // authors Dipankar <[email protected]> | ||
|
|
||
| import ( | ||
| "context" | ||
| "os" | ||
|
|
||
| "github.com/ksctl/ksctl/pkg/helpers" | ||
|
|
||
| "github.com/ksctl/ksctl/pkg/helpers/consts" | ||
| "github.com/spf13/cobra" | ||
| ) | ||
|
|
||
| var deleteNodesHAAws = &cobra.Command{ | ||
| Use: "delete-nodes", | ||
| Short: "Use to delete a HA aws k3s cluster", | ||
| Long: `It is used to delete cluster with the given name from user. For example: | ||
| ksctl delete-cluster ha-azure delete-nodes <arguments to civo cloud provider> | ||
| `, | ||
| Run: func(cmd *cobra.Command, args []string) { | ||
| verbosity, _ := cmd.Flags().GetInt("verbose") | ||
| SetRequiredFeatureFlags(cmd) | ||
|
|
||
| cli.Client.Metadata.LogVerbosity = verbosity | ||
| cli.Client.Metadata.LogWritter = os.Stdout | ||
| cli.Client.Metadata.Provider = consts.CloudAws | ||
| cli.Client.Metadata.IsHA = true | ||
|
|
||
| SetDefaults(consts.CloudAws, consts.ClusterTypeHa) | ||
|
|
||
| cli.Client.Metadata.NoWP = noWP | ||
| cli.Client.Metadata.ClusterName = clusterName | ||
| cli.Client.Metadata.Region = region | ||
| cli.Client.Metadata.K8sDistro = consts.KsctlKubernetes(distro) | ||
|
|
||
| if err := safeInitializeStorageLoggerFactory(context.WithValue(context.Background(), "USERID", helpers.GetUserName())); err != nil { | ||
| log.Error("Failed Initialize Storage Driver", "Reason", err) | ||
| os.Exit(1) | ||
| } | ||
|
|
||
| if err := deleteApproval(cmd.Flags().Lookup("approve").Changed); err != nil { | ||
| log.Error(err.Error()) | ||
| os.Exit(1) | ||
| } | ||
|
|
||
| err := controller.DelWorkerPlaneNode(&cli.Client) | ||
| if err != nil { | ||
| log.Error("Failed to scale down", "Reason", err) | ||
| os.Exit(1) | ||
| } | ||
| log.Success("Scale down successful") | ||
| }, | ||
| } | ||
|
|
||
| func init() { | ||
| deleteClusterHAAws.AddCommand(deleteNodesHAAws) | ||
|
|
||
| clusterNameFlag(deleteNodesHAAws) | ||
| noOfWPFlag(deleteNodesHAAws) | ||
| regionFlag(deleteNodesHAAws) | ||
| distroFlag(deleteNodesHAAws) | ||
| storageFlag(deleteNodesHAAws) | ||
|
|
||
| deleteNodesHAAws.MarkFlagRequired("name") | ||
| deleteNodesHAAws.MarkFlagRequired("region") | ||
| } |
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.