Added the ability to run go-datakit tests on Windows

Signed-off-by: Simon Ferquel <[email protected]>

api/go-datakit/README

@@ -0,0 +1 @@
+To run test on windows, launch the a datakit server with --url \\.\pipe\datakit-test

api/go-datakit/client_test.go

@@ -50,11 +50,7 @@ func TestInit(t *testing.T) {
 		t.Fatalf("Mkdir failed: %v", err)
 	}
 	filePath := append(path, "filename")
-	largeFilePath := append(path, "largefile")
-	var largeDataInput []byte
-	for ix := 0; ix < client.session.MaxReadSize()+150; ix++ {
-		largeDataInput = append(largeDataInput, byte(ix))
-	}
+
 	err = client.Remove(ctx, filePath...)
 	if err != nil {
 		t.Fatalf("Remove failed: %v", err)
@@ -82,6 +78,13 @@ func TestInit(t *testing.T) {
 	file.Close(ctx)
 	file.Close(ctx) // should be idempotent
 
+	t.Logf("max read size is %v", client.session.MaxReadSize())
+	t.Logf("max write size is %v", client.session.MaxWriteSize())
+	largeFilePath := append(path, "largefile")
+	var largeDataInput []byte
+	for ix := 0; ix < client.session.MaxReadSize()*2+150; ix++ {
+		largeDataInput = append(largeDataInput, byte(ix))
+	}
 	file, err = client.Create(ctx, largeFilePath...)
 	if err != nil {
 		t.Fatalf("Create %v failed: %v", filePath, err)
@@ -94,6 +97,7 @@ func TestInit(t *testing.T) {
 	if n != len(largeDataInput) {
 		t.Fatalf("Write was only partial: %v", err)
 	}
+	t.Logf("Written %v bytes successfully", n)
 	readBackData := make([]byte, len(largeDataInput)+2) // make sure reported length when ReadAll is called has the right value
 	n, err = io.ReadFull(file.NewIOReader(ctx, 0), readBackData)
 	if err != nil && err != io.EOF && err != io.ErrUnexpectedEOF {
@@ -105,4 +109,5 @@ func TestInit(t *testing.T) {
 	if bytes.Compare(largeDataInput, readBackData[:n]) != 0 {
 		t.Fatalf("The message we read back was different to the message we wrote")
 	}
+	t.Logf("Read %v bytes successfully", n)
 }

api/go-datakit/config_test.go

@@ -8,10 +8,6 @@ import (
 	"golang.org/x/net/context"
 )
 
-func dial(ctx context.Context) (*Client, error) {
-	return Dial(ctx, "unix", "/var/tmp/foo")
-}
-
 func TestConfig(t *testing.T) {
 	ctx := context.Background()
 	log.Println("Testing the configuration interface")

api/go-datakit/dial_test.go

@@ -0,0 +1,9 @@
+// +build linux darwin
+
+package datakit
+
+import "golang.org/x/net/context"
+
+func dial(ctx context.Context) (*Client, error) {
+	return Dial(ctx, "unix", "/var/tmp/foo")
+}

api/go-datakit/dial_windows_test.go

@@ -0,0 +1,15 @@
+package datakit
+
+import (
+	"context"
+
+	"github.com/Microsoft/go-winio"
+)
+
+func dial(ctx context.Context) (*Client, error) {
+	conn, err := winio.DialPipe(`\\.\pipe\datakit-test`, nil)
+	if err != nil {
+		return nil, err
+	}
+	return NewClient(ctx, conn)
+}