remove kind the binary as a dependnecy

Bump the kind library dep to v0.4.0

Signed-off-by: Chuck Ha <[email protected]>

Author: chuckha

Dockerfile

@@ -12,7 +12,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-FROM golang:1.12.5
+FROM golang:1.12.6
 WORKDIR /cluster-api-provider-docker
 ADD go.mod .
 ADD go.sum .
@@ -25,12 +25,10 @@ ADD execer execer
 ADD third_party third_party
 
 RUN go install -v ./cmd/capd-manager
-RUN GO111MODULE="on" go get sigs.k8s.io/[email protected]
 RUN curl https://get.docker.com | sh
 
 FROM golang:1.12.5
 COPY --from=0 /cluster-api-provider-docker/kubernetes/client/bin/kubectl /usr/local/bin
 COPY --from=0 /go/bin/capd-manager /usr/local/bin
-COPY --from=0 /go/bin/kind /usr/local/bin
 COPY --from=0 /usr/bin/docker /usr/local/bin
 ENTRYPOINT ["capd-manager"]

actuators/machine.go

@@ -103,12 +103,12 @@ func (m *Machine) Create(ctx context.Context, c *clusterv1.Cluster, machine *clu
 			fmt.Printf("%+v\n", err)
 			return err
 		}
-		lbip, err := elb.IP()
+		lbipv4, _, err := elb.IP()
 		if err != nil {
 			fmt.Printf("%+v\n", err)
 			return err
 		}
-		controlPlaneNode, err := actions.CreateControlPlane(c.Name, machine.GetName(), lbip, machine.Spec.Versions.ControlPlane)
+		controlPlaneNode, err := actions.CreateControlPlane(c.Name, machine.GetName(), lbipv4, machine.Spec.Versions.ControlPlane, nil)
 		if err != nil {
 			fmt.Printf("%+v\n", err)
 			return err

cmd/capdctl/main.go

@@ -18,13 +18,18 @@ package main
 
 import (
 	"encoding/json"
+	"errors"
 	"flag"
 	"fmt"
 	"io/ioutil"
 	"os"
+	"sigs.k8s.io/cluster-api-provider-docker/kind/actions"
+	"sigs.k8s.io/kind/pkg/cluster/nodes"
+	"sigs.k8s.io/kind/pkg/container/cri"
+	"sigs.k8s.io/kind/pkg/exec"
+	"time"
 
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	"sigs.k8s.io/cluster-api-provider-docker/execer"
 	"sigs.k8s.io/cluster-api/pkg/apis/cluster/v1alpha1"
 )
 
@@ -62,7 +67,7 @@ func (mo *machineDeyploymentOptions) initFlags(fs *flag.FlagSet) {
 
 func main() {
 	setup := flag.NewFlagSet("setup", flag.ExitOnError)
-	managementClusterName := setup.String("cluster-name", "kind", "The name of the management cluster")
+	managementClusterName := setup.String("cluster-name", "management", "The name of the management cluster")
 
 	// crds takes no args
 
@@ -91,6 +96,7 @@ func main() {
 	if len(os.Args) < 2 {
 		fmt.Println("At least one subcommand is requied.")
 		fmt.Println(usage())
+		os.Exit(1)
 	}
 
 	switch os.Args[1] {
@@ -242,37 +248,43 @@ func machineYAML(opts *machineOptions) string {
 }
 
 func makeManagementCluster(clusterName string) {
-	kind := execer.NewClient("kind")
-	// start kind with docker mount
-	kindConfig, err := kindConfigFile()
+	fmt.Println("Creating a brand new cluster")
+	elb, err := actions.SetUpLoadBalancer(clusterName)
 	if err != nil {
 		panic(err)
 	}
-	if err := kind.RunCommand("create", "cluster", "--name", clusterName, "--config", kindConfig); err != nil {
+	lbipv4, _, err := elb.IP()
+	if err != nil {
 		panic(err)
 	}
-}
-
-// TODO if possible, use the kind library instead of the command line tool
-func kindConfigFile() (string, error) {
-	kfg := `kind: Cluster
-apiVersion: kind.sigs.k8s.io/v1alpha3
-nodes:
-- role: control-plane
-  extraMounts:
-  - containerPath: /var/run/docker.sock
-    hostPath: /var/run/docker.sock
-`
-
-	f, err := ioutil.TempFile("", "*-kind-config.yaml")
+	cpMounts := []cri.Mount{
+		{
+			ContainerPath: "/var/run/docker.sock",
+			HostPath: "/var/run/docker.sock",
+		},
+	}
+	cp, err := actions.CreateControlPlane(clusterName, "management-control-plane", lbipv4, "v1.14.2", cpMounts)
 	if err != nil {
-		return "", err
+		panic(err)
+	}
+	if !nodes.WaitForReady(cp, time.Now().Add(5*time.Minute)) {
+		panic(errors.New("control plane was not ready in 5 minutes"))
 	}
-	defer f.Close()
-	if _, err := f.WriteString(kfg); err != nil {
-		return "", err
+	f, err := ioutil.TempFile("", "crds")
+	if err != nil {
+		panic(err)
+	}
+	defer os.Remove(f.Name())
+	fmt.Fprintln(f, crds)
+	fmt.Fprintln(f, "---")
+	fmt.Fprintln(f, getCAPDPlane("gcr.io/kubernetes1-226021/capd-manager:latest", "gcr.io/k8s-cluster-api/cluster-api-controller:0.1.3"))
+	cmd := exec.Command("kubectl", "apply", "-f", f.Name())
+	cmd.SetEnv(fmt.Sprintf("KUBECONFIG=%s/.kube/kind-config-%s", os.Getenv("HOME"), clusterName))
+	cmd.SetStdout(os.Stdout)
+	cmd.SetStderr(os.Stderr)
+	if err := cmd.Run(); err != nil {
+		panic(err)
 	}
-	return f.Name(), nil
 }
 
 func printCRDs() {
@@ -376,6 +388,17 @@ spec:
         - /manager
         image: %s
         name: manager
+      tolerations:
+      - effect: NoSchedule
+        key: node-role.kubernetes.io/master
+      - key: CriticalAddonsOnly
+        operator: Exists
+      - effect: NoExecute
+        key: node.alpha.kubernetes.io/notReady
+        operator: Exists
+      - effect: NoExecute
+        key: node.alpha.kubernetes.io/unreachable
+        operator: Exists
 `
 
 // TODO generate the CRDs

cmd/kind-test/main.go

@@ -44,11 +44,11 @@ func main() {
 			if err != nil {
 				panic(fmt.Sprintf("%+v", err))
 			}
-			ip, err := lb.IP()
+			lbipv4, _, err := lb.IP()
 			if err != nil {
 				panic(fmt.Sprintf("%+v", err))
 			}
-			if _, err := actions.CreateControlPlane(clusterName, inputs[1], ip, version); err != nil {
+			if _, err := actions.CreateControlPlane(clusterName, inputs[1], lbipv4, version, nil); err != nil {
 				panic(fmt.Sprintf("%+v", err))
 			}
 		case "add-worker":

execer/client.go

@@ -28,7 +28,7 @@ require (
 	k8s.io/kubernetes v1.13.1
 	sigs.k8s.io/cluster-api v0.0.0-20190607141803-aacb0c613ffb
 	sigs.k8s.io/controller-runtime v0.1.10
-	sigs.k8s.io/kind v0.3.0
+	sigs.k8s.io/kind v0.4.0
 	sigs.k8s.io/testing_frameworks v0.1.1 // indirect
 )
 

go.mod

@@ -195,6 +195,8 @@ sigs.k8s.io/controller-runtime v0.1.10 h1:amLOmcekVdnsD1uIpmgRqfTbQWJ2qxvQkcdeFh
 sigs.k8s.io/controller-runtime v0.1.10/go.mod h1:HFAYoOh6XMV+jKF1UjFwrknPbowfyHEHHRdJMf2jMX8=
 sigs.k8s.io/kind v0.3.0 h1:TUIRsJZy123ejyWECuYOU2XzSsIsauoqaeoUGsfdj6k=
 sigs.k8s.io/kind v0.3.0/go.mod h1:bgGo2cWxKGQ7esVxtGp9H17Ttlexju92CTMjCg08HNQ=
+sigs.k8s.io/kind v0.4.0 h1:C/QMxmF5Sp3yyKkTJ5+VJPcclZyu/JV8wLyihZbsHaI=
+sigs.k8s.io/kind v0.4.0/go.mod h1:bgGo2cWxKGQ7esVxtGp9H17Ttlexju92CTMjCg08HNQ=
 sigs.k8s.io/kustomize v2.0.3+incompatible h1:JUufWFNlI44MdtnjUqVnvh29rR37PQFzPbLXqhyOyX0=
 sigs.k8s.io/kustomize v2.0.3+incompatible/go.mod h1:MkjgH3RdOWrievjo6c9T245dYlB5QeXV4WCbnt/PEpU=
 sigs.k8s.io/structured-merge-diff v0.0.0-20190426204423-ea680f03cc65/go.mod h1:wWxsB5ozmmv/SG7nM11ayaAW51xMvak/t1r0CSlcokI=