Initial Implementation of kubectl deploy

Author: FabianKramm

pkg/devspace/deploy/kubectl/kubectl.go

@@ -1 +1,50 @@
 package kubectl
+
+import (
+	"path/filepath"
+
+	"github.com/covexo/devspace/pkg/util/yamlutil"
+
+	"k8s.io/client-go/kubernetes"
+)
+
+// Deploy deploys all specified manifests via kubectl apply and adds to the specified image names the corresponding tags
+func Deploy(client *kubernetes.Clientset, namespace string, images []string, tags map[string]string, manifests []string) error {
+	for _, pattern := range manifests {
+		files, err := filepath.Glob(pattern)
+		if err != nil {
+			return err
+		}
+
+		for _, file := range files {
+			err = applyFile(client, file, namespace, images, tags)
+			if err != nil {
+				return err
+			}
+		}
+	}
+
+	return nil
+}
+
+func applyFile(client *kubernetes.Clientset, file string, namespace string, images []string, tags map[string]string) error {
+	y := make(map[interface{}]interface{})
+	yamlutil.ReadYamlFromFile(file, y)
+
+	match := func(key, value string) bool {
+		return false
+	}
+
+	replace := func(value string) string {
+		return ""
+	}
+
+	Walk(y, match, replace)
+
+	//changedManifest, err := yaml.Marshal(y)
+	//if err != nil {
+	//	return err
+	//}
+
+	return nil
+}

pkg/devspace/deploy/kubectl/walk.go

@@ -0,0 +1,30 @@
+package kubectl
+
+// ReplaceFn defines the replace function
+type ReplaceFn func(value string) string
+
+// MatchFn defines the match function
+type MatchFn func(key, value string) bool
+
+// Walk walks over an interface and replaces keys that match the match function with the replace function
+func Walk(d interface{}, match MatchFn, replace ReplaceFn) {
+	switch t := d.(type) {
+	case map[interface{}]interface{}:
+		for k, v := range t {
+			key := k.(string)
+			value, ok := v.(string)
+			if ok == false {
+				Walk(v, match, replace)
+				continue
+			}
+
+			if match(key, value) {
+				t[k] = replace(value)
+			}
+		}
+	case []interface{}:
+		for _, val := range t {
+			Walk(val, match, replace)
+		}
+	}
+}