feat(deisctl): kubectl for install and uninstall

Author: technosophos

trireme/k8s/decode.go

@@ -0,0 +1,19 @@
+package k8s
+
+import (
+//"k8s.io/kubernetes/pkg/api/latest"
+//"k8s.io/kubernetes/pkg/runtime"
+)
+
+/*
+func DecodeFile(path string, o runtime.Object) error {
+	data, err := ioutil.ReadFile(path)
+	if err != nil {
+		return err
+	}
+
+	if err := latest.Codec.DecodeInto(data, o); err != nil {
+		return err
+	}
+}
+*/

trireme/k8s/kubectl.go

@@ -0,0 +1,31 @@
+package k8s
+
+import (
+	"fmt"
+	"os/exec"
+)
+
+// The plan is to eventually call all of these commands directly from the
+// k8s API. For the sake of expedience, this is a convenience wrapper until
+// we get there.
+
+// KubectlCreate calls 'kubectl create'.
+func KubectlCreate(file string) error {
+	out, err := exec.Command("kubectl", "create", "-f", file).CombinedOutput()
+	if err != nil {
+		fmt.Printf("%s\n", out)
+		return err
+	}
+	fmt.Printf("Scheduled %s", out)
+	return nil
+}
+
+func KubectlDelete(filename string) error {
+	out, err := exec.Command("kubectl", "delete", "-f", filename).CombinedOutput()
+	if err != nil {
+		fmt.Printf("%s\n", out)
+		return err
+	}
+	fmt.Printf("Deleting %s", out)
+	return nil
+}

trireme/main.go

@@ -11,46 +11,52 @@ import (
 )
 
 // Components, in the order in which they must be started.
+//
+// This list describes all of the components that the CLI has the ability to
+// manage. When things are installed, namespaces, services, volumes and secrets
+// are installed first, then pods and rcs are installed.
 var components = []*platform.Component{
 	{
 		Name:        "builder",
 		Description: "the builder",
-		RCs:         []string{"deis-builder.json"},
-		Services:    []string{"deis-builder-service.json"},
+		Namespaces:  []string{"namespaces/deis-namespace.json"},
+		RCs:         []string{"rcs/deis-builder.json"},
+		Services:    []string{"services/deis-builder-service.json"},
 	},
 	{
 		Name:        "controller",
 		Description: "the controller",
-		RCs:         []string{"deis-controller.json"},
-		Services:    []string{"deis-controller-service.json"},
+		RCs:         []string{"rcs/deis-controller.json"},
+		Services:    []string{"services/deis-controller-service.json"},
 	},
 	{
 		Name:        "database",
 		Description: "the database",
-		RCs:         []string{"deis-database.json"},
-		Services:    []string{"deis-database-service.json"},
+		RCs:         []string{"rcs/deis-database.json"},
+		Services:    []string{"services/deis-database-service.json"},
 	},
 	{
 		Name:        "registry",
 		Description: "the registry",
-		RCs:         []string{"deis-registry.json"},
-		Services:    []string{"deis-registry-service.json"},
+		RCs:         []string{"rcs/deis-registry.json"},
+		Services:    []string{"services/deis-registry-service.json"},
 	},
 	{
 		Name:        "router",
 		Description: "the router mesh",
-		RCs:         []string{"router.json"},
-		Services:    []string{"router-service.json"},
+		RCs:         []string{"rcs/deis-router.json"},
+		//Services:    []string{"services/deis-router-service.json"},
 	},
 	{
 		Name:        "store",
 		Description: "the persistent storage cluster",
-		RCs:         []string{"deis-store-gtw.json", "deis-store-mds.json", "deis-store-mon.json", "deis-store-osd.json"},
-		Services:    []string{"deis-store-gtw-service.json"},
+		RCs:         []string{"rcs/deis-store-gtw.json", "rcs/deis-store-mds.json", "rcs/deis-store-mon.json", "rcs/deis-store-osd.json"},
+		Services:    []string{"services/deis-store-gtw-service.json"},
 		Optional:    true,
 	},
 }
 
+// config is where configuration data is stored.
 var config storage.Storer
 
 func main() {
@@ -68,21 +74,35 @@ func main() {
 	app := cli.NewApp()
 	app.Name = "trireme"
 	app.Usage = "A control tool for Deis"
+	app.Flags = []cli.Flag{
+		// This is currently not used.
+		cli.StringFlag{
+			Name:   "tunnel, t",
+			Value:  "127.0.0.1",
+			EnvVar: "DEISCTL_TUNNEL",
+			Usage:  "The IP address or hostname of the tunnel.",
+		},
+	}
 	app.Commands = commands()
 	app.Run(os.Args)
 }
 
 func commands() []cli.Command {
 	return []cli.Command{
+		{
+			Name:        "config",
+			Usage:       "Get and set configuration values",
+			Subcommands: configCommands(),
+		},
 		{
 			Name:        "install",
 			Usage:       "Install platform components",
 			Subcommands: installCommands(),
 		},
 		{
-			Name:        "config",
-			Usage:       "Get and set configuration values",
-			Subcommands: configCommands(),
+			Name:        "uninstall",
+			Usage:       "Uninstall platform components",
+			Subcommands: uninstallCommands(),
 		},
 	}
 }
@@ -200,7 +220,6 @@ func configCommands() []cli.Command {
 }
 
 func installCommands() []cli.Command {
-
 	// This basically ensures that append() will not have to reallocate.
 	cmds := make([]cli.Command, 0, len(components)+1)
 
@@ -219,10 +238,10 @@ func installCommands() []cli.Command {
 		Action: installPlatform,
 		Flags: []cli.Flag{
 			cli.StringFlag{
-				Name:   "units, u",
-				Value:  "units/",
+				Name:   "unit-files, u",
+				Value:  "./units/",
 				Usage:  "The path to the Deis Kubernetes JSON unit files.",
-				EnvVar: "DEIS_K8S_UNITS",
+				EnvVar: "DEISCTL_UNITS",
 			},
 			cli.StringFlag{
 				Name:   "registry, r",
@@ -231,29 +250,89 @@ func installCommands() []cli.Command {
 			},
 		},
 	})
+	return cmds
+}
+func uninstallCommands() []cli.Command {
+	// This basically ensures that append() will not have to reallocate.
+	cmds := make([]cli.Command, 0, len(components)+1)
 
+	for _, c := range components {
+		n := c.Name
+		v := c.Description
+		cmds = append(cmds, cli.Command{
+			Name:   n,
+			Usage:  fmt.Sprintf("Uninstall %s.", v),
+			Action: func(c *cli.Context) { uninstallComponent(c, n) },
+		})
+	}
+	cmds = append(cmds, cli.Command{
+		Name:   "platform",
+		Usage:  "Uninstall the entire platform",
+		Action: uninstallPlatform,
+		Flags: []cli.Flag{
+			cli.StringFlag{
+				Name:   "unit-files, u",
+				Value:  "./units/",
+				Usage:  "The path to the Deis Kubernetes JSON unit files.",
+				EnvVar: "DEISCTL_UNITS",
+			},
+			cli.StringFlag{
+				Name:   "registry, r",
+				Usage:  "The URL to a Docker registry that holds Deis images images.",
+				EnvVar: "DEV_REGISTRY",
+			},
+		},
+	})
 	return cmds
 }
 
 func installPlatform(c *cli.Context) {
 	fmt.Println("Installing platform")
-	if err := platform.InstallAll(components, false); err != nil {
+
+	dir := c.String("unit-files")
+	if err := platform.InstallAll(components, dir, false); err != nil {
 		fmt.Printf("Failed to install platform: %s\n", err)
 		os.Exit(500)
 	}
 }
+
+func uninstallPlatform(c *cli.Context) {
+	dir := c.String("unit-files")
+	if err := platform.DeleteAll(components, dir); err != nil {
+		fmt.Printf("Failed to uninstall platform: %s\n", err)
+		os.Exit(500)
+	}
+}
 func installComponent(c *cli.Context, name string) {
 	comp, err := findComponent(name)
 	if err != nil {
 		fmt.Printf("Failed to install %s: %s\n", name, err)
 		os.Exit(404)
 	}
-	if err := comp.InstallPrereqs(); err != nil {
-		fmt.Printf("Failed to install prereqs of %s: %s\n", name, err)
+	dir := c.String("unit-files")
+	if err := comp.Install(dir); err != nil {
+		fmt.Printf("Failed to install %s: %s\n", name, err)
 		os.Exit(500)
 	}
-	if err := comp.Install(); err != nil {
-		fmt.Printf("Failed to install %s: %s\n", name, err)
+	if err := comp.InstallPrereqs(dir); err != nil {
+		fmt.Printf("Failed to install dependencies of %s: %s\n", name, err)
+		os.Exit(500)
+	}
+}
+
+func uninstallComponent(c *cli.Context, name string) {
+	comp, err := findComponent(name)
+	if err != nil {
+		fmt.Printf("Failed to uninstall %s: %s\n", name, err)
+		os.Exit(404)
+	}
+	dir := c.String("unit-files")
+	if err := comp.Delete(dir); err != nil {
+		fmt.Printf("Failed to uninstall %s: %s\n", name, err)
+		os.Exit(500)
+	}
+	if err := comp.DeletePrereqs(dir); err != nil {
+		fmt.Printf("Failed to uninstall dependencies of %s: %s\n", name, err)
 		os.Exit(500)
 	}
 }