Skip to content

Commit

Permalink
remove utils ProviderAndManager that create two unrelated object
Browse files Browse the repository at this point in the history
  • Loading branch information
mavimo committed Aug 23, 2018
1 parent cbfc457 commit f393126
Show file tree
Hide file tree
Showing 8 changed files with 9 additions and 24 deletions.
3 changes: 2 additions & 1 deletion cmd/cluster_add_worker.go
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,8 @@ You can specify the worker server type as in cluster create.`,
}

coordinator := pkg.NewProgressCoordinator()
hetznerProvider, clusterManager := hetzner.ProviderAndManager(AppConf.Context, *cluster, AppConf.Client, AppConf.SSHClient, coordinator, AppConf.CurrentContext.Token)
hetznerProvider := hetzner.NewHetznerProvider(AppConf.Context, AppConf.Client, *cluster, AppConf.CurrentContext.Token)
clusterManager := clustermanager.NewClusterManagerFromCluster(*cluster, hetznerProvider, AppConf.SSHClient, coordinator)
err := AppConf.SSHClient.(*clustermanager.SSHCommunicator).CapturePassphrase(sshKeyName)
if err != nil {
log.Fatal(err)
Expand Down
2 changes: 1 addition & 1 deletion cmd/cluster_addon.go
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ func validateAddonSubCommand(cmd *cobra.Command, args []string) error {
return errors.New("exactly one argument expected")
}
addonName := args[0]
provider, _ := hetzner.ProviderAndManager(AppConf.Context, *cluster, AppConf.Client, AppConf.SSHClient, nil, AppConf.CurrentContext.Token)
provider := hetzner.NewHetznerProvider(AppConf.Context, AppConf.Client, *cluster, AppConf.CurrentContext.Token)
addonService := addons.NewClusterAddonService(provider, AppConf.SSHClient)
if !addonService.AddonExists(addonName) {
return fmt.Errorf("addon %s not found", addonName)
Expand Down
2 changes: 1 addition & 1 deletion cmd/cluster_addon_install.go
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ var clusterAddonInstallCmd = &cobra.Command{
_, cluster := AppConf.Config.FindClusterByName(name)

log.Printf("installing addon %s", addonName)
provider, _ := hetzner.ProviderAndManager(AppConf.Context, *cluster, AppConf.Client, AppConf.SSHClient, nil, AppConf.CurrentContext.Token)
provider := hetzner.NewHetznerProvider(AppConf.Context, AppConf.Client, *cluster, AppConf.CurrentContext.Token)
addonService := addons.NewClusterAddonService(provider, AppConf.SSHClient)
masterNode, err := provider.GetMasterNode()
FatalOnError(err)
Expand Down
2 changes: 1 addition & 1 deletion cmd/cluster_addon_list.go
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ var clusterAddonListCmd = &cobra.Command{
fmt.Fprintln(tw, "NAME\tREQUIRES\tDESCRIPTION\tURL")

cluster := &clustermanager.Cluster{Nodes: []clustermanager.Node{clustermanager.Node{IsMaster: true}}}
provider, _ := hetzner.ProviderAndManager(AppConf.Context, *cluster, AppConf.Client, AppConf.SSHClient, nil, AppConf.CurrentContext.Token)
provider := hetzner.NewHetznerProvider(AppConf.Context, AppConf.Client, *cluster, AppConf.CurrentContext.Token)
addonService := addons.NewClusterAddonService(provider, AppConf.SSHClient)
for _, addon := range addonService.Addons() {
requires := "-"
Expand Down
2 changes: 1 addition & 1 deletion cmd/cluster_addon_uninstall.go
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ var clusterAddonUninstallCmd = &cobra.Command{
_, cluster := AppConf.Config.FindClusterByName(name)

log.Printf("removing addon %s", addonName)
provider, _ := hetzner.ProviderAndManager(AppConf.Context, *cluster, AppConf.Client, AppConf.SSHClient, nil, AppConf.CurrentContext.Token)
provider := hetzner.NewHetznerProvider(AppConf.Context, AppConf.Client, *cluster, AppConf.CurrentContext.Token)
masterNode, err := provider.GetMasterNode()
FatalOnError(err)

Expand Down
3 changes: 2 additions & 1 deletion cmd/cluster_create_test.go
Original file line number Diff line number Diff line change
@@ -1,8 +1,9 @@
package cmd

import (
"github.com/xetys/hetzner-kube/pkg/clustermanager"
"testing"

"github.com/xetys/hetzner-kube/pkg/clustermanager"
)

func TestClusterCmdValidate(t *testing.T) {
Expand Down
2 changes: 1 addition & 1 deletion cmd/cluster_kubeconfig.go
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ Example 4: hetzner-kube cluster kubeconfig -n my-cluster -p > my-conf.yaml # pri
name := args[0]
_, cluster := AppConf.Config.FindClusterByName(name)

provider, _ := hetzner.ProviderAndManager(AppConf.Context, *cluster, AppConf.Client, AppConf.SSHClient, nil, AppConf.CurrentContext.Token)
provider := hetzner.NewHetznerProvider(AppConf.Context, AppConf.Client, *cluster, AppConf.CurrentContext.Token)
masterNode, err := provider.GetMasterNode()
FatalOnError(err)

Expand Down
17 changes: 0 additions & 17 deletions pkg/hetzner/util.go

This file was deleted.

0 comments on commit f393126

Please sign in to comment.