merged main

Signed-off-by: AlexsJones <alexsimonjones@gmail.com>

pkg/kubernetes/kubernetes.go

@@ -0,0 +1,35 @@
+package kubernetes
+
+import (
+	"k8s.io/client-go/kubernetes"
+	"k8s.io/client-go/rest"
+	"k8s.io/client-go/tools/clientcmd"
+)
+
+type Client struct {
+	client *kubernetes.Clientset
+}
+
+func (c *Client) GetClient() *kubernetes.Clientset {
+	return c.client
+}
+
+func NewClient(masterURL string, kubeconfig string) (*Client, error) {
+
+	config, err := rest.InClusterConfig()
+	if err != nil {
+		kubeconfig :=
+			clientcmd.NewDefaultClientConfigLoadingRules().GetDefaultFilename()
+		config, err = clientcmd.BuildConfigFromFlags(masterURL, kubeconfig)
+		if err != nil {
+			return nil, err
+		}
+	}
+	clientSet, err := kubernetes.NewForConfig(config)
+	if err != nil {
+		return nil, err
+	}
+	return &Client{
+		client: clientSet,
+	}, nil
+}