Merge pull request #7 from utkarsh-pro/utkarsh-pro/feature/detect_kub…

…econfig

Add DetectKubeConfig and createNamespaceIfNotExist functions

utils/kubernetes/apply-manifest.go

@@ -1,10 +1,14 @@
 package kubernetes
 
 import (
-	kubeerror "k8s.io/apimachinery/pkg/api/errors"
+	"context"
 	"strings"
 
+	v1 "k8s.io/api/core/v1"
+	"k8s.io/apimachinery/pkg/api/errors"
+	kubeerror "k8s.io/apimachinery/pkg/api/errors"
 	meta "k8s.io/apimachinery/pkg/api/meta"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
 	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/apimachinery/pkg/runtime/schema"
@@ -53,6 +57,10 @@ func (client *Client) ApplyManifest(contents []byte, options ApplyOptions) error
 			options.Namespace = val
 		}
 
+		if err = createNamespaceIfNotExist(client.Clientset, context.TODO(), options.Namespace); err != nil {
+			return ErrApplyManifest(err)
+		}
+
 		if options.Delete {
 			_, err = deleteObject(helper, options.Namespace, object)
 			if err != nil {
@@ -118,3 +126,13 @@ func deleteObject(restHelper *resource.Helper, namespace string, obj runtime.Obj
 	}
 	return restHelper.Delete(namespace, name)
 }
+
+func createNamespaceIfNotExist(kubeClientset kubernetes.Interface, ctx context.Context, namespace string) error {
+	nsSpec := &v1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: namespace}}
+	_, err := kubeClientset.CoreV1().Namespaces().Create(ctx, nsSpec, metav1.CreateOptions{})
+	if !errors.IsAlreadyExists(err) {
+		return err
+	}
+
+	return nil
+}

utils/kubernetes/detect-kubeconfig.go

@@ -0,0 +1,34 @@
+package kubernetes
+
+import (
+	"os"
+	"path"
+
+	"github.com/layer5io/meshkit/utils"
+	"k8s.io/client-go/rest"
+	"k8s.io/client-go/tools/clientcmd"
+)
+
+// DetectKubeConfig detects the kubeconfig for the kubernetes cluster and returns it
+func DetectKubeConfig() (config *rest.Config, err error) {
+	// If deployed within the cluster
+	if config, err = rest.InClusterConfig(); err == nil {
+		return config, err
+	}
+
+	// Look for kubeconfig from the path mentioned in $KUBECONFIG
+	kubeconfig := os.Getenv("KUBECONFIG")
+	if kubeconfig != "" {
+		if config, err = clientcmd.BuildConfigFromFlags("", kubeconfig); err == nil {
+			return config, err
+		}
+	}
+
+	// Look for kubeconfig at the default path
+	path := path.Join(utils.GetHome(), ".kube", "config")
+	if config, err = clientcmd.BuildConfigFromFlags("", path); err == nil {
+		return config, err
+	}
+
+	return
+}