Commit fc40bc8d authored by Adam Reese's avatar Adam Reese

fix(cli): use kubectl builder consistently

parent 61a9296b
...@@ -123,11 +123,12 @@ func dmCmd() cli.Command { ...@@ -123,11 +123,12 @@ func dmCmd() cli.Command {
} }
func installServer(c *cli.Context) error { func installServer(c *cli.Context) error {
dryRun := c.Bool("dry-run")
resImg := c.String("resourcifier-image") resImg := c.String("resourcifier-image")
ebImg := c.String("expandybird-image") ebImg := c.String("expandybird-image")
manImg := c.String("manager-image") manImg := c.String("manager-image")
runner := getKubectlRunner(dryRun)
dryRun := c.Bool("dry-run")
runner := buildKubectlRunner(dryRun)
i := client.NewInstaller() i := client.NewInstaller()
i.Manager["Image"] = manImg i.Manager["Image"] = manImg
...@@ -144,7 +145,7 @@ func installServer(c *cli.Context) error { ...@@ -144,7 +145,7 @@ func installServer(c *cli.Context) error {
func uninstallServer(c *cli.Context) error { func uninstallServer(c *cli.Context) error {
dryRun := c.Bool("dry-run") dryRun := c.Bool("dry-run")
runner := getKubectlRunner(dryRun) runner := buildKubectlRunner(dryRun)
out, err := client.Uninstall(runner) out, err := client.Uninstall(runner)
if err != nil { if err != nil {
...@@ -156,12 +157,9 @@ func uninstallServer(c *cli.Context) error { ...@@ -156,12 +157,9 @@ func uninstallServer(c *cli.Context) error {
func statusServer(c *cli.Context) error { func statusServer(c *cli.Context) error {
dryRun := c.Bool("dry-run") dryRun := c.Bool("dry-run")
client := kubectl.Client runner := buildKubectlRunner(dryRun)
if dryRun {
client = kubectl.PrintRunner{}
}
out, err := client.GetByKind("pods", "", "dm") out, err := runner.GetByKind("pods", "", "dm")
if err != nil { if err != nil {
return err return err
} }
...@@ -169,23 +167,20 @@ func statusServer(c *cli.Context) error { ...@@ -169,23 +167,20 @@ func statusServer(c *cli.Context) error {
return nil return nil
} }
func getKubectlRunner(dryRun bool) kubectl.Runner {
if dryRun {
return &kubectl.PrintRunner{}
}
return &kubectl.RealRunner{}
}
func targetServer(c *cli.Context) error { func targetServer(c *cli.Context) error {
dryRun := c.Bool("dry-run") dryRun := c.Bool("dry-run")
client := kubectl.Client runner := buildKubectlRunner(dryRun)
if dryRun { out, err := runner.ClusterInfo()
client = kubectl.PrintRunner{}
}
out, err := client.ClusterInfo()
if err != nil { if err != nil {
return fmt.Errorf("%s (%s)", out, err) return fmt.Errorf("%s (%s)", out, err)
} }
format.Msg(string(out)) format.Msg(string(out))
return nil return nil
} }
func buildKubectlRunner(dryRun bool) kubectl.Runner {
if dryRun {
return &kubectl.PrintRunner{}
}
return &kubectl.RealRunner{}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment