Add boilerplate for clusterctl

clusterctl/.gitignore

@@ -0,0 +1 @@
+clusterctl

clusterctl/CONTRIBUTING.md

@@ -0,0 +1 @@
+# Contributing Guidelines

clusterctl/README.md

@@ -0,0 +1,61 @@
+# clusterctl
+
+`clusterctl` is the SIG-cluster-lifecycle sponsored tool that implements the Cluster API.
+
+Read the [experience doc here](https://docs.google.com/document/d/1-sYb3EdkRga49nULH1kSwuQFf1o6GvAw_POrsNo5d8c/edit#).
+
+## Getting Started
+
+### Prerequisites
+
+Follow the steps listed at [CONTRIBUTING.md](https://github.com/kubernetes/kube-deploy/blob/master/cluster-api/clusterctl/CONTRIBUTING.md) to:
+
+1. Build the `clusterctl` tool 
+3. Create a `machines.yaml` file configured for your cluster. See the provided template for an example.
+
+### Limitation
+
+
+### Creating a cluster
+
+**NOT YET SUPPORTED!**
+
+In order to create a cluster with the Cluster API, the user will supply these:
+
+* Cluster which defines the spec common across the entire cluster.
+* Machine which defines the spec of a machine. Further abstractions of
+MachineSets and MachineClass and MachineDeployments are supported as well.
+* Extras (optional) spec extras.yaml file with specs of all controllers
+(ConfigMaps) that the cluster needs. This would include the Machine controller,
+MachineSet controller, Machine Setup ConfigMap etc. Note that this is not a new API
+object. There will be defaults running. This will make the tool easily pluggage
+(change the controller spec) instead of changing the tool or mucking with flags.
+
+1. Create a cluster: `./clusterctl create cluster -c cluster.yaml -m machines.yaml -e extras.yaml`
+
+### Interacting with your cluster
+
+Once you have created a cluster, you can interact with the cluster and machine
+resources using kubectl:
+
+```
+$ kubectl get clusters
+$ kubectl get machines
+$ kubectl get machines -o yaml
+```
+
+#### Scaling your cluster
+
+**NOT YET SUPPORTED!**
+
+#### Upgrading your cluster
+
+**NOT YET SUPPORTED!**
+
+#### Node repair
+
+**NOT YET SUPPORTED!**
+
+### Deleting a cluster
+
+**NOT YET SUPPORTED!**

clusterctl/cmd/create.go

@@ -0,0 +1,71 @@
+/*
+Copyright 2018 The Kubernetes Authors.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package cmd
+
+import (
+	"os"
+
+	//"fmt"
+	"github.com/golang/glog"
+	"github.com/spf13/cobra"
+	"sigs.k8s.io/cluster-api/errors"
+)
+
+type CreateOptions struct {
+	Cluster string
+	Machine string
+	Extras  string
+}
+
+var co = &CreateOptions{}
+
+var createCmd = &cobra.Command{
+	Use:   "create",
+	Short: "Create kubernetes cluster",
+	Long:  `Create a kubernetes cluster with one command`,
+	Run: func(cmd *cobra.Command, args []string) {
+		if co.Cluster == "" {
+			glog.Error("Please provide yaml file for cluster definition.")
+			cmd.Help()
+			os.Exit(1)
+		}
+		if co.Machine == "" {
+			glog.Error("Please provide yaml file for machine definition.")
+			cmd.Help()
+			os.Exit(1)
+		}
+		if co.Extras == "" {
+			glog.Error("Please provide a yaml file for extra definitions (controllers, Addons etc).")
+			cmd.Help()
+			os.Exit(1)
+		}
+		if err := RunCreate(co); err != nil {
+			glog.Exit(err)
+		}
+	},
+}
+
+func RunCreate(co *CreateOptions) error {
+	return errors.NotImplementedError
+}
+func init() {
+	createCmd.Flags().StringVarP(&co.Cluster, "cluster", "c", "", "cluster yaml file")
+	createCmd.Flags().StringVarP(&co.Machine, "machines", "m", "", "machine yaml file")
+	createCmd.Flags().StringVarP(&co.Extras, "extras", "e", "", "extras yaml file")
+
+	RootCmd.AddCommand(createCmd)
+}

clusterctl/cmd/delete.go

@@ -0,0 +1,56 @@
+/*
+Copyright 2018 The Kubernetes Authors.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package cmd
+
+import (
+	"github.com/golang/glog"
+	"github.com/spf13/cobra"
+	"os"
+	"sigs.k8s.io/cluster-api/errors"
+)
+
+type DeleteOptions struct {
+	ClusterName string
+}
+
+var do = &DeleteOptions{}
+
+var deleteCmd = &cobra.Command{
+	Use:   "delete",
+	Short: "Delete kubernetes cluster",
+	Long:  `Delete a kubernetes cluster with one command`,
+	Run: func(cmd *cobra.Command, args []string) {
+		if do.ClusterName == "" {
+			glog.Error("Please provide cluster name.")
+			cmd.Help()
+			os.Exit(1)
+		}
+		if err := RunDelete(); err != nil {
+			glog.Exit(err)
+		}
+	},
+}
+
+func RunDelete() error {
+	return errors.NotImplementedError
+}
+
+func init() {
+	deleteCmd.Flags().StringVarP(&do.ClusterName, "cluster-name", "n", "", "cluster name")
+
+	RootCmd.AddCommand(deleteCmd)
+}

clusterctl/cmd/register.go

@@ -0,0 +1,57 @@
+/*
+Copyright 2018 The Kubernetes Authors.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package cmd
+
+import (
+	"os"
+
+	"github.com/golang/glog"
+	"github.com/spf13/cobra"
+	"sigs.k8s.io/cluster-api/errors"
+)
+
+type RegisterOptions struct {
+	RegistryEndpoint string
+}
+
+var ro = &RegisterOptions{}
+
+var registerCmd = &cobra.Command{
+	Use:   "register",
+	Short: "Register a kubernetes cluster with a Cluster Registry",
+	Long:  `Register a kubernetes cluster with a Cluster Registry`,
+	Run: func(cmd *cobra.Command, args []string) {
+		if ro.RegistryEndpoint == "" {
+			glog.Error("Please provide yaml file for cluster definition.")
+			cmd.Help()
+			os.Exit(1)
+		}
+		if err := RunRegister(ro); err != nil {
+			glog.Exit(err)
+		}
+	},
+}
+
+func RunRegister(co *RegisterOptions) error {
+	return errors.NotImplementedError
+}
+
+func init() {
+	registerCmd.Flags().StringVarP(&ro.RegistryEndpoint, "registry-endpoint", "r", "", "registry endpoint")
+
+	RootCmd.AddCommand(registerCmd)
+}

clusterctl/cmd/root.go

@@ -0,0 +1,85 @@
+/*
+Copyright 2018 The Kubernetes Authors.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package cmd
+
+import (
+	"flag"
+	"io/ioutil"
+
+	"github.com/ghodss/yaml"
+	"github.com/golang/glog"
+	"github.com/spf13/cobra"
+	"k8s.io/apiserver/pkg/util/logs"
+	clusterv1 "sigs.k8s.io/cluster-api/pkg/apis/cluster/v1alpha1"
+	"sigs.k8s.io/cluster-api/util"
+)
+
+var RootCmd = &cobra.Command{
+	Use:   "clusterctl",
+	Short: "cluster management",
+	Long:  `Simple kubernetes cluster management`,
+	Run: func(cmd *cobra.Command, args []string) {
+		// Do Stuff Here
+		cmd.Help()
+	},
+}
+
+var (
+	kubeConfig string
+)
+
+func Execute() {
+	if err := RootCmd.Execute(); err != nil {
+		glog.Exit(err)
+	}
+}
+
+func parseClusterYaml(file string) (*clusterv1.Cluster, error) {
+	bytes, err := ioutil.ReadFile(file)
+	if err != nil {
+		return nil, err
+	}
+
+	cluster := &clusterv1.Cluster{}
+	err = yaml.Unmarshal(bytes, cluster)
+	if err != nil {
+		return nil, err
+	}
+
+	return cluster, nil
+}
+
+func parseMachinesYaml(file string) ([]*clusterv1.Machine, error) {
+	bytes, err := ioutil.ReadFile(file)
+	if err != nil {
+		return nil, err
+	}
+
+	machines := &clusterv1.MachineList{}
+	err = yaml.Unmarshal(bytes, &machines)
+	if err != nil {
+		return nil, err
+	}
+
+	return util.MachineP(machines.Items), nil
+}
+
+func init() {
+	RootCmd.PersistentFlags().StringVarP(&kubeConfig, "kubeconfig", "k", "", "location for the kubernetes config file. If not provided, $HOME/.kube/config is used")
+	flag.CommandLine.Parse([]string{})
+	logs.InitLogs()
+}

clusterctl/main.go

@@ -0,0 +1,23 @@
+/*
+Copyright 2018 The Kubernetes Authors.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package main
+
+import "sigs.k8s.io/cluster-api/clusterctl/cmd"
+
+func main() {
+	cmd.Execute()
+}

errors/deployer.go

@@ -0,0 +1,23 @@
+/*
+Copyright 2018 The Kubernetes Authors.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package errors
+
+import (
+	"fmt"
+)
+
+var NotImplementedError = fmt.Errorf("not implemented")