test(integration): use the new kind options

Signed-off-by: Lorenzo Fontana <[email protected]>

Author: fntlnz

integration/suite_test.go

@@ -8,16 +8,17 @@ import (
 	"testing"
 	"time"
 
+	"github.com/davecgh/go-spew/spew"
 	"github.com/go-check/check"
 	"github.com/iovisor/kubectl-trace/pkg/cmd"
 	"gotest.tools/icmd"
 	"sigs.k8s.io/kind/pkg/cluster"
 	"sigs.k8s.io/kind/pkg/cluster/config/encoding"
+	"sigs.k8s.io/kind/pkg/cluster/create"
 )
 
 var (
 	KubectlTraceBinary = os.Getenv("TEST_KUBECTLTRACE_BINARY")
-	KindImageTag       = os.Getenv("TEST_KIND_IMAGETAG")
 )
 
 type KubectlTraceSuite struct {
@@ -30,26 +31,20 @@ func init() {
 		KubectlTraceBinary = "kubectl-trace"
 	}
 
-	if KindImageTag == "" {
-		KindImageTag = "kindest/node:v1.12.3"
-	}
 	check.Suite(&KubectlTraceSuite{})
 }
 
 func (k *KubectlTraceSuite) SetUpSuite(c *check.C) {
 	cfg, err := encoding.Load("")
 	c.Assert(err, check.IsNil)
-	retain := false
-	wait := time.Duration(0)
-
 	err = cfg.Validate()
 	c.Assert(err, check.IsNil)
 
 	clusterName, err := generateClusterName()
 	c.Assert(err, check.IsNil)
 	kctx := cluster.NewContext(clusterName)
 
-	err = kctx.Create(cfg, retain, wait)
+	err = kctx.Create(cfg, create.Retain(false), create.WaitForReady(time.Duration(0)))
 	c.Assert(err, check.IsNil)
 	k.kindContext = kctx
 
@@ -61,12 +56,14 @@ func (k *KubectlTraceSuite) SetUpSuite(c *check.C) {
 	for _, n := range nodes {
 		loadcomm := fmt.Sprintf("docker save %s | docker exec -i %s docker load", cmd.ImageNameTag, n.String())
 		res := icmd.RunCommand("bash", "-c", loadcomm)
+		spew.Dump(loadcomm)
+		spew.Dump(res)
 		c.Assert(res.Error, check.IsNil)
 	}
 }
 
-func (s *KubectlTraceSuite) TearDownSuite(c *check.C) {
-	err := s.kindContext.Delete()
+func (k *KubectlTraceSuite) TearDownSuite(c *check.C) {
+	err := k.kindContext.Delete()
 	c.Assert(err, check.IsNil)
 }