Add docker-machine operator (#1)

Signed-off-by: Shaad7 <abdullah.alshaad@appscode.com>
Signed-off-by: Tamal Saha <tamal@appscode.com>

Author: AbdullahAlShaad

.dockerignore

@@ -1,26 +1,34 @@
-
-# Binaries for programs and plugins
-*.exe
-*.exe~
-*.dll
+# Compiled Object files, Static and Dynamic libs (Shared Objects)
+*.o
+*.a
 *.so
-*.dylib
-bin/*
-Dockerfile.cross
 
-# Test binary, build with `go test -c`
-*.test
+# Folders
+_obj
+_test
 
-# Output of the go coverage tool, specifically when used with LiteIDE
-*.out
+# Architecture specific extensions/prefixes
+*.cgo1.go
+*.cgo2.c
+_cgo_defun.c
+_cgo_gotypes.go
+_cgo_export.*
 
-# Kubernetes Generated files - skip generated files, except for vendored files
+_testmain.go
+
+*.exe
+*.test
+*.prof
 
-!vendor/**/zz_generated.*
+/bin
+/.go
 
-# editor and IDE paraphernalia
-.idea
-.vscode
-*.swp
-*.swo
-*~
+/.idea
+/.markdownlint.json
+/.vscode
+/apiserver.local.config
+/coverage.txt
+/dist
+/hack/config/.env
+/test/e2e/junit.xml
+/test/e2e/report.xml

.gitignore

@@ -12,7 +12,19 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-FROM ghcr.io/appscode/dlv:1.20.1
+FROM alpine
+
+ARG TARGETARCH
+
+RUN set -x \
+    && apk add --no-cache ca-certificates \
+    && wget -O rancher-machine.tar.gz https://github.com/rancher/machine/releases/download/v0.15.0-rancher103/rancher-machine-${TARGETARCH}.tar.gz \
+    && tar xzf rancher-machine.tar.gz \
+    && chmod +x rancher-machine \
+    && mv rancher-machine docker-machine
+
+
+FROM ghcr.io/appscode/dlv:1.20.1 as build-env
 
 FROM {ARG_FROM}
 
@@ -21,12 +33,14 @@ LABEL org.opencontainers.image.source https://github.com/cluster-api/docker-mach
 RUN set -x \
   && apt-get update \
   && apt-get upgrade -y \
-  && apt-get install -y --no-install-recommends ca-certificates \
+  && apt-get install -y --no-install-recommends ca-certificates openssh-client \
   && rm -rf /var/lib/apt/lists/* /usr/share/doc /usr/share/man /tmp/* \
   && echo 'Etc/UTC' > /etc/timezone
 
 ADD bin/{ARG_BIN}-{ARG_OS}-{ARG_ARCH} /{ARG_BIN}
-COPY --from=0 /usr/local/bin/dlv /bin/dlv
+COPY --from=build-env /usr/local/bin/dlv /bin/dlv
+
+COPY --from=0 /docker-machine /bin/docker-machine
 
 EXPOSE 40000
 

Dockerfile.dbg

@@ -12,16 +12,29 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
+FROM alpine
+
+ARG TARGETARCH
+
+RUN set -x \
+    && apk add --no-cache ca-certificates \
+    && wget -O rancher-machine.tar.gz https://github.com/rancher/machine/releases/download/v0.15.0-rancher103/rancher-machine-${TARGETARCH}.tar.gz \
+    && tar xzf rancher-machine.tar.gz \
+    && chmod +x rancher-machine \
+    && mv rancher-machine docker-machine
+
 FROM {ARG_FROM}
 
 LABEL org.opencontainers.image.source https://github.com/cluster-api/docker-machine-operator
 
 RUN set -x \
-  && apk add --update --upgrade --no-cache pcre2 ca-certificates tzdata \
+  && apk add --update --upgrade --no-cache pcre2 ca-certificates tzdata openssh-client \
   && echo 'Etc/UTC' > /etc/timezone
 
 ADD bin/{ARG_BIN}-{ARG_OS}-{ARG_ARCH} /{ARG_BIN}
 
+COPY --from=0 /docker-machine /bin/docker-machine
+
 USER 65534
 
 ENTRYPOINT ["/{ARG_BIN}"]

Dockerfile.in

@@ -20,16 +20,11 @@ import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 )
 
-// EDIT THIS FILE!  THIS IS SCAFFOLDING FOR YOU TO OWN!
-// NOTE: json tags are required.  Any new fields you add must have json tags for the fields to be serialized.
-
 // DriverSpec defines the desired state of Driver
 type DriverSpec struct {
-	// INSERT ADDITIONAL SPEC FIELDS - desired state of cluster
-	// Important: Run "make" to regenerate code after modifying this file
-
-	// Foo is an example field of Driver. Edit driver_types.go to remove/update
-	Foo string `json:"foo,omitempty"`
+	Builtin bool `json:"builtin"`
+	// +optional
+	DownloadURL string `json:"downloadURL,omitempty"`
 }
 
 // DriverStatus defines the observed state of Driver

api/v1alpha1/driver_types.go

@@ -0,0 +1,105 @@
+/*
+Copyright AppsCode Inc. and Contributors.
+
+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 v1alpha1
+
+import (
+	"fmt"
+
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	kmapi "kmodules.xyz/client-go/api/v1"
+)
+
+type MachinePhase string
+
+const (
+	MachineConditionTypeMachineReady  kmapi.ConditionType = "MachineReady"
+	MachineConditionTypeScriptReady   kmapi.ConditionType = "ScriptReady"
+	MachineConditionTypeAuthDataReady kmapi.ConditionType = "AuthDataReady"
+	MachineConditionTypeClusterReady  kmapi.ConditionType = "ClusterReady"
+)
+
+const (
+	MachineConditionClusterCreatedSuccessfully = "ClusterCreatedSuccessfully"
+	MachineConditionClusterCreateFailed        = "ClusterCreateFailed"
+	MachineConditionWaitingForScriptCompletion = "WaitingForScriptCompletion"
+	MachineConditionAuthDataNotFound           = "AuthDataNotFound"
+	MachineConditionScriptDataNotFound         = "ScriptDataNotFound"
+	MachineConditionMachineCreating            = "MachineCreating"
+)
+
+const (
+	MachinePhasePending                MachinePhase = "Pending"
+	MachinePhaseInProgress             MachinePhase = "InProgress"
+	MachinePhaseWaitingForClusterReady MachinePhase = "WaitingForClusterReady"
+	MachinePhaseClusterCreateFailed    MachinePhase = "ClusterCreateFailed"
+	MachinePhaseSuccess                MachinePhase = "Success"
+	MachinePhaseTerminating            MachinePhase = "Terminating"
+	MachinePhaseFailed                 MachinePhase = "Failed"
+)
+
+func ConditionsOrder() []kmapi.ConditionType {
+	return []kmapi.ConditionType{
+		MachineConditionTypeClusterReady,
+		MachineConditionTypeMachineReady,
+		MachineConditionTypeAuthDataReady,
+		MachineConditionTypeScriptReady,
+	}
+}
+
+func GetPhase(obj *Machine) MachinePhase {
+	if !obj.GetDeletionTimestamp().IsZero() {
+		return MachinePhaseTerminating
+	}
+	conditions := obj.GetConditions()
+	if len(conditions) == 0 {
+		return MachinePhaseInProgress
+	}
+	var cond kmapi.Condition
+	for i := range conditions {
+		c := conditions[i]
+		if c.Type == kmapi.ReadyCondition {
+			cond = c
+			break
+		}
+	}
+	if cond.Type != kmapi.ReadyCondition {
+		panic(fmt.Sprintf("no Ready condition in the status for %s/%s", obj.GetNamespace(), obj.GetName()))
+	}
+
+	if cond.Status == metav1.ConditionTrue {
+		return MachinePhaseSuccess
+	}
+
+	if cond.Reason == MachineConditionAuthDataNotFound ||
+		cond.Reason == MachineConditionScriptDataNotFound {
+		return MachinePhaseFailed
+	}
+	if cond.Reason == MachineConditionMachineCreating {
+		return MachinePhaseInProgress
+	}
+	if cond.Reason == MachineConditionWaitingForScriptCompletion {
+		return MachinePhaseWaitingForClusterReady
+	}
+	if cond.Reason == MachineConditionClusterCreateFailed {
+		return MachineConditionClusterCreateFailed
+	}
+	return MachinePhaseFailed
+}
+
+func GetFinalizer() string {
+	return GroupVersion.Group
+}

api/v1alpha1/helper.go

@@ -17,31 +17,36 @@ limitations under the License.
 package v1alpha1
 
 import (
+	core "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	kmapi "kmodules.xyz/client-go/api/v1"
 )
 
-// EDIT THIS FILE!  THIS IS SCAFFOLDING FOR YOU TO OWN!
-// NOTE: json tags are required.  Any new fields you add must have json tags for the fields to be serialized.
-
 // MachineSpec defines the desired state of Machine
 type MachineSpec struct {
-	// INSERT ADDITIONAL SPEC FIELDS - desired state of cluster
-	// Important: Run "make" to regenerate code after modifying this file
-
-	// Foo is an example field of Machine. Edit machine_types.go to remove/update
-	Foo string `json:"foo,omitempty"`
+	Driver     *core.LocalObjectReference `json:"driver"`
+	ScriptRef  *kmapi.ObjectReference     `json:"scriptRef"`
+	AuthSecret *kmapi.ObjectReference     `json:"authSecret"`
+	Parameters map[string]string          `json:"parameters"`
 }
 
 // MachineStatus defines the observed state of Machine
 type MachineStatus struct {
-	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
-	// Important: Run "make" to regenerate code after modifying this file
+	// +optional
+	// +listType=map
+	// +listMapKey=type
+	// +kubebuilder:validation:MaxItems=8
+	Conditions []kmapi.Condition `json:"conditions"`
+	// +optional
+	Phase MachinePhase `json:"phase"`
 }
 
-//+kubebuilder:object:root=true
-//+kubebuilder:subresource:status
-
 // Machine is the Schema for the machines API
+
+// +kubebuilder:object:root=true
+// +kubebuilder:subresource:status
+// +kubebuilder:printcolumn:name="Status",type="string",JSONPath=".status.phase"
+// +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp"
 type Machine struct {
 	metav1.TypeMeta   `json:",inline"`
 	metav1.ObjectMeta `json:"metadata,omitempty"`
@@ -62,3 +67,15 @@ type MachineList struct {
 func init() {
 	SchemeBuilder.Register(&Machine{}, &MachineList{})
 }
+
+func (in *Machine) GetStatus() *MachineStatus {
+	return &in.Status
+}
+
+func (in *Machine) GetConditions() kmapi.Conditions {
+	return in.Status.Conditions
+}
+
+func (in *Machine) SetConditions(conditions kmapi.Conditions) {
+	in.Status.Conditions = conditions
+}