Add gomod, update travis

.travis.yml

-sudo: false
+os:
+  - linux
 
 language: go
 
 go:
   - 1.11.x
 
+env:
+  global:
+    - GOTFLAGS="-race -cpu=5"
+  matrix:
+    - BUILD_DEPTYPE=gx
+    - BUILD_DEPTYPE=gomod
+
+
+# disable travis install
 install:
-  - make deps
+  - true
 
 script:
   - bash <(curl -s https://raw.githubusercontent.com/ipfs/ci-helpers/master/travis-ci/run-standard-tests.sh)
 
+
 cache:
   directories:
     - $GOPATH/src/gx
+    - $GOPATH/pkg/mod
+    - $HOME/.cache/go-build
 
 notifications:
   email: false
-
-env: GOTFLAGS="-race -cpu=5" GOVETCMD="go vet -methods=false"

chan_test.go

@@ -2,13 +2,18 @@ package msgio
 
 import (
 	"bytes"
-	randbuf "github.com/jbenet/go-randbuf"
 	"io"
 	"math/rand"
 	"testing"
 	"time"
 )
 
+func randBuf(r *rand.Rand, size int) []byte {
+	buf := make([]byte, size)
+	_, _ = r.Read(buf)
+	return buf
+}
+
 func TestReadChan(t *testing.T) {
 	buf := bytes.NewBuffer(nil)
 	writer := NewWriter(buf)
@@ -17,7 +22,7 @@ func TestReadChan(t *testing.T) {
 
 	r := rand.New(rand.NewSource(time.Now().UnixNano()))
 	for i := range msgs {
-		msgs[i] = randbuf.RandBuf(r, r.Intn(1000))
+		msgs[i] = randBuf(r, r.Intn(1000))
 		err := writer.WriteMsg(msgs[i])
 		if err != nil {
 			t.Fatal(err)
@@ -65,7 +70,7 @@ func TestWriteChan(t *testing.T) {
 
 	r := rand.New(rand.NewSource(time.Now().UnixNano()))
 	for i := range msgs {
-		msgs[i] = randbuf.RandBuf(r, r.Intn(1000))
+		msgs[i] = randBuf(r, r.Intn(1000))
 
 		select {
 		case err := <-wchan.ErrChan:

go.mod

+module github.com/libp2p/go-msgio
+
+require github.com/libp2p/go-buffer-pool v0.0.1

go.sum

+github.com/libp2p/go-buffer-pool v0.0.1 h1:9Rrn/H46cXjaA2HQ5Y8lyhOS1NhTkZ4yuEs2r3Eechg=
+github.com/libp2p/go-buffer-pool v0.0.1/go.mod h1:xtyIz9PMobb13WaxR6Zo1Pd1zXJKYg0a8KiIvDp3TzQ=

msgio_test.go

@@ -10,8 +10,6 @@ import (
 	"sync"
 	"testing"
 	"time"
-
-	randbuf "github.com/jbenet/go-randbuf"
 )
 
 func TestReadWrite(t *testing.T) {
@@ -93,7 +91,7 @@ func SubtestReadWrite(t *testing.T, writer WriteCloser, reader ReadCloser) {
 
 	r := rand.New(rand.NewSource(time.Now().UnixNano()))
 	for i := range msgs {
-		msgs[i] = randbuf.RandBuf(r, r.Intn(1000))
+		msgs[i] = randBuf(r, r.Intn(1000))
 		n, err := writer.Write(msgs[i])
 		if err != nil {
 			t.Fatal(err)
@@ -137,7 +135,7 @@ func SubtestReadWriteMsg(t *testing.T, writer WriteCloser, reader ReadCloser) {
 
 	r := rand.New(rand.NewSource(time.Now().UnixNano()))
 	for i := range msgs {
-		msgs[i] = randbuf.RandBuf(r, r.Intn(1000))
+		msgs[i] = randBuf(r, r.Intn(1000))
 		err := writer.WriteMsg(msgs[i])
 		if err != nil {
 			t.Fatal(err)
@@ -176,7 +174,7 @@ func SubtestReadWriteMsgSync(t *testing.T, writer WriteCloser, reader ReadCloser
 
 	r := rand.New(rand.NewSource(time.Now().UnixNano()))
 	for i := range msgs {
-		msgs[i] = randbuf.RandBuf(r, r.Intn(1000)+4)
+		msgs[i] = randBuf(r, r.Intn(1000)+4)
 		NBO.PutUint32(msgs[i][:4], uint32(i))
 	}