e2e test with kubernetes-sigs/kind

e2e/e2e.go

@@ -0,0 +1,51 @@
+package e2e
+
+import (
+	"io/ioutil"
+	"os"
+	"testing"
+
+	"k8s.io/client-go/kubernetes"
+	"k8s.io/client-go/tools/clientcmd"
+	"sigs.k8s.io/kind/pkg/cluster"
+)
+
+/* Contains utilities to:
+ * 1. bootstrap a kind cluster and to stop it
+ * 2. deploy profefe
+ * 3. Deploy some other application/s for testing
+ * 5. Deploying kprofefe
+ */
+
+func CreateCluster(t *testing.T, name string) (*kubernetes.Clientset, func() error) {
+	provider := cluster.NewProvider()
+	if err := provider.Create(name); err != nil {
+		t.Error(err)
+		return nil, func() error { return nil }
+	}
+
+	tmpfile, err := ioutil.TempFile("", name)
+	if err != nil {
+		t.Error(err)
+		return nil, func() error { return nil }
+	}
+	t.Log(tmpfile.Name())
+
+	config, err := clientcmd.BuildConfigFromFlags("", tmpfile.Name())
+	if err != nil {
+		t.Error(err)
+		return nil, func() error { return nil }
+	}
+
+	clientset, err := kubernetes.NewForConfig(config)
+	if err != nil {
+		return nil, func() error { return nil }
+	}
+
+	return clientset, func() error {
+		if err := provider.Delete(name, tmpfile.Name()); err != nil {
+			return err
+		}
+		return os.Remove(tmpfile.Name())
+	}
+}

e2e/e2e_test.go

@@ -0,0 +1,21 @@
+package e2e
+
+import (
+	"testing"
+	"time"
+
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+func TestCreateCluster(t *testing.T) {
+	clientset, shutdown := CreateCluster(t, "random")
+	time.Sleep(10 * time.Second)
+	if err := shutdown(); err != nil {
+		t.Fatal(err)
+	}
+	n, err := clientset.CoreV1().Namespaces().List(metav1.ListOptions{})
+	if err != nil {
+		t.Fatal(err)
+	}
+	t.Fatal(n.Kind)
+}

go.mod

@@ -3,30 +3,38 @@ module github.com/gianarb/kube-profefe
 go 1.13
 
 require (
+	github.com/alessio/shellescape v1.2.2 // indirect
 	github.com/docker/go-units v0.4.0 // indirect
 	github.com/docker/spdystream v0.0.0-20181023171402-6480d4af844c // indirect
 	github.com/elazarl/goproxy v0.0.0-20190410145444-c548f45dcf1d // indirect
 	github.com/elazarl/goproxy/ext v0.0.0-20190410145444-c548f45dcf1d // indirect
-	github.com/evanphx/json-patch v4.5.0+incompatible // indirect
 	github.com/gogo/protobuf v1.3.1 // indirect
+	github.com/google/gofuzz v1.1.0 // indirect
 	github.com/google/pprof v0.0.0-20191105193234-27840fff0d09
 	github.com/googleapis/gnostic v0.3.0 // indirect
 	github.com/gorilla/mux v1.7.3 // indirect
 	github.com/gregjones/httpcache v0.0.0-20181110185634-c63ab54fda8f // indirect
 	github.com/imdario/mergo v0.3.6 // indirect
 	github.com/konsorten/go-windows-terminal-sequences v1.0.2 // indirect
+	github.com/mattn/go-isatty v0.0.12 // indirect
+	github.com/onsi/ginkgo v1.11.0 // indirect
+	github.com/pelletier/go-toml v1.7.0 // indirect
+	github.com/pkg/errors v0.9.1 // indirect
 	github.com/sirupsen/logrus v1.4.2 // indirect
-	github.com/spf13/cobra v0.0.5
+	github.com/spf13/cobra v1.0.0
 	github.com/spf13/pflag v1.0.5
 	github.com/testcontainers/testcontainers-go v0.0.10
 	go.opentelemetry.io/otel v0.2.4-0.20200307183859-3bf3927eb55d
 	go.opentelemetry.io/otel/exporters/trace/jaeger v0.2.4-0.20200307183859-3bf3927eb55d
 	go.uber.org/zap v1.13.0
 	golang.org/x/crypto v0.0.0-20190923035154-9ee001bba392 // indirect
-	golang.org/x/sys v0.0.0-20191010194322-b09406accb47 // indirect
 	google.golang.org/appengine v1.6.1 // indirect
+	gopkg.in/yaml.v3 v3.0.0-20200121175148-a6ecf24a6d71 // indirect
 	k8s.io/api v0.17.3
 	k8s.io/apimachinery v0.17.3
 	k8s.io/cli-runtime v0.17.3
 	k8s.io/client-go v0.17.3
+	k8s.io/kube-openapi v0.0.0-20200121204235-bf4fb3bd569c // indirect
+	sigs.k8s.io/kind v0.7.0
+	sigs.k8s.io/yaml v1.2.0 // indirect
 )