add sample test

Signed-off-by: Denis Tingajkin <denis.tingajkin@xored.com>
networkservicemesh · Oct 29, 2020 · 9bbbe23 · 9bbbe23
1 parent 930a397
commit 9bbbe23
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 4 deletions.
diff --git a/k8s/k8s.go b/k8s/k8s.go
@@ -18,6 +18,7 @@
 package k8s
 
 import (
+	"context"
 	"fmt"
 	"io/ioutil"
 	"os"
@@ -73,7 +74,7 @@ func ApplyDeployment(path string, mutators ...func(deployment *v1.Deployment)) e
 	for _, m := range mutators {
 		m(&d)
 	}
-	_, err = client.AppsV1().Deployments(namespace).Create(&d)
+	_, err = client.AppsV1().Deployments(namespace).Create(context.Background(), &d, metav1.CreateOptions{})
 	return err
 }
 
@@ -86,7 +87,7 @@ func ShowLogs(options ...*exechelper.Option) {
 		return
 	}
 
-	pods, err := client.CoreV1().Pods(namespace).List(metav1.ListOptions{})
+	pods, err := client.CoreV1().Pods(namespace).List(context.Background(), metav1.ListOptions{})
 
 	if err != nil {
 		logrus.Errorf("Cannot get pods: %v", err.Error())

diff --git a/k8s/require/require.go b/k8s/require/require.go
@@ -18,6 +18,7 @@
 package require
 
 import (
+	"context"
 	"fmt"
 	"testing"
 
@@ -31,7 +32,7 @@ import (
 func NoRestarts(t *testing.T) {
 	c, err := k8s.Client()
 	require.NoError(t, err)
-	list, err := c.CoreV1().Pods("default").List(metav1.ListOptions{})
+	list, err := c.CoreV1().Pods("default").List(context.Background(), metav1.ListOptions{})
 	require.NoError(t, err)
 	for i := 0; i < len(list.Items); i++ {
 		pod := &list.Items[i]

diff --git a/spire/spire.go b/spire/spire.go
@@ -18,6 +18,8 @@
 package spire
 
 import (
+	"context"
+
 	"github.com/edwarnicke/exechelper"
 	"github.com/pkg/errors"
 	v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -30,7 +32,7 @@ func exist() bool {
 	if err != nil {
 		return false
 	}
-	_, err = client.CoreV1().Namespaces().Get("spire", v1.GetOptions{})
+	_, err = client.CoreV1().Namespaces().Get(context.Background(), "spire", v1.GetOptions{})
 	return err == nil
 }