Fix Windows compatibility for v5

statsd/pipe_windows_test.go

@@ -87,14 +87,15 @@ func TestPipeWriterReconnect(t *testing.T) {
 
 	out := make(chan string)
 	go acceptOne(t, ln, out)
+
 	client, err := New(pipepath)
 	require.Nil(t, err)
 
 	// first attempt works, then connection closes
 	err = client.Gauge("metric", 1, []string{"key:val"}, 1)
 	require.Nil(t, err, "Failed to send gauge: %s", err)
 
-	timeout := time.After(1 * time.Second)
+	timeout := time.After(5 * time.Second)
 	select {
 	case got := <-out:
 		assert.Equal(t, got, "metric:1|g|#key:val\n")
@@ -120,7 +121,7 @@ func TestPipeWriterReconnect(t *testing.T) {
 		err = client.Gauge("metric", 3, []string{"key:val"}, 1)
 		require.Nil(t, err, "Failed to send second gauge: %s", err)
 
-		timeout = time.After(500 * time.Millisecond)
+		timeout = time.After(3 * time.Second)
 		select {
 		case got := <-out:
 			assert.Equal(t, got, "metric:3|g|#key:val\n")

statsd/uds_windows.go

@@ -2,9 +2,13 @@
 
 package statsd
 
-import "fmt"
+import (
+	"fmt"
+	"io"
+	"time"
+)
 
-// newUDSWriter is disable on windows as unix sockets are not available
-func newUDSWriter(addr string) (io.WriteCloser, error) {
-	return nil, fmt.Errorf("unix socket is not available on windows")
+// newUDSWriter is disabled on Windows as Unix sockets are not available.
+func newUDSWriter(_ string, _ time.Duration) (io.WriteCloser, error) {
+	return nil, fmt.Errorf("Unix socket is not available on Windows")
 }