aporeto-inc
diff --git a/‎.travis.yml
+9-11 b/‎.travis.yml
+9-11
diff --git a/‎Gopkg.lock
-168 b/‎Gopkg.lock
-168
diff --git a/‎Gopkg.toml
-48 b/‎Gopkg.toml
-48
diff --git a/‎Makefile
+2-3 b/‎Makefile
+2-3
diff --git a/‎README.md
+8-8 b/‎README.md
+8-8
diff --git a/‎buffer/buffer.go
+15-8 b/‎buffer/buffer.go
+15-8
@@ -1,11 +1,8 @@
 language: go
 
 go:
-  - 1.8.x
-  - 1.9.x
-  - 1.10.x
-
-sudo: false
+  - 1.15.x
+  - 1.x
 
 go_import_path: github.com/vulcand/oxy
 
@@ -14,12 +11,13 @@ notifications:
     on_success: never
     on_failure: change
 
+env:
+  - GO111MODULE=on
+
 before_install:
-  - go get -u github.com/golang/lint/golint
-  - go get -u github.com/client9/misspell/cmd/misspell
-  - curl -sI https://github.com/golang/dep/releases/latest | grep -Fi Location  | tr -d '\r' | sed "s/tag/download/g" | awk -F " " '{ print $2 "/dep-linux-amd64"}' | wget --output-document=$GOPATH/bin/dep -i -
-  - chmod +x $GOPATH/bin/dep
+  - GO111MODULE=off go get -u golang.org/x/lint/golint
+  - GO111MODULE=off go get -u github.com/client9/misspell/cmd/misspell
 
 install:
-  - make dependencies
-  - git diff --exit-code Gopkg.lock
+  - go mod tidy
+  - git diff --exit-code go.mod go.sum
@@ -1,5 +1,7 @@
 .PHONY: all
 
+export GO111MODULE=on
+
 PKGS := $(shell go list ./... | grep -v '/vendor/')
 GOFILES := $(shell go list -f '{{range $$index, $$element := .GoFiles}}{{$$.Dir}}/{{$$element}}{{"\n"}}{{end}}' ./... | grep -v '/vendor/')
 TXT_FILES := $(shell find * -type f -not -path 'vendor/**')
@@ -14,9 +16,6 @@ test: clean
 test-verbose: clean
 	go test -v -race -cover $(PKGS)
 
-dependencies:
-	dep ensure -v
-
 clean:
 	find . -name flymake_* -delete
 	rm -f cover.out
 
@@ -3,14 +3,14 @@ Oxy [![Build Status](https://travis-ci.org/vulcand/oxy.svg?branch=master)](https
 
 Oxy is a Go library with HTTP handlers that enhance HTTP standard library:
 
-* [Buffer](http://godoc.org/github.com/vulcand/oxy/buffer) retries and buffers requests and responses 
-* [Stream](http://godoc.org/github.com/vulcand/oxy/stream) passes-through requests, supports chunked encoding with configurable flush interval 
-* [Forward](http://godoc.org/github.com/vulcand/oxy/forward) forwards requests to remote location and rewrites headers 
-* [Roundrobin](http://godoc.org/github.com/vulcand/oxy/roundrobin) is a round-robin load balancer 
-* [Circuit Breaker](http://godoc.org/github.com/vulcand/oxy/cbreaker) Hystrix-style circuit breaker
-* [Connlimit](http://godoc.org/github.com/vulcand/oxy/connlimit) Simultaneous connections limiter
-* [Ratelimit](http://godoc.org/github.com/vulcand/oxy/ratelimit) Rate limiter (based on tokenbucket algo)
-* [Trace](http://godoc.org/github.com/vulcand/oxy/trace) Structured request and response logger
+* [Buffer](https://pkg.go.dev/github.com/vulcand/oxy/buffer) retries and buffers requests and responses 
+* [Stream](https://pkg.go.dev/github.com/vulcand/oxy/stream) passes-through requests, supports chunked encoding with configurable flush interval 
+* [Forward](https://pkg.go.dev/github.com/vulcand/oxy/forward) forwards requests to remote location and rewrites headers 
+* [Roundrobin](https://pkg.go.dev/github.com/vulcand/oxy/roundrobin) is a round-robin load balancer 
+* [Circuit Breaker](https://pkg.go.dev/github.com/vulcand/oxy/cbreaker) Hystrix-style circuit breaker
+* [Connlimit](https://pkg.go.dev/github.com/vulcand/oxy/connlimit) Simultaneous connections limiter
+* [Ratelimit](https://pkg.go.dev/github.com/vulcand/oxy/ratelimit) Rate limiter (based on tokenbucket algo)
+* [Trace](https://pkg.go.dev/github.com/vulcand/oxy/trace) Structured request and response logger
 
 It is designed to be fully compatible with http standard library, easy to customize and reuse.
 
 
@@ -179,7 +179,7 @@ func MemRequestBodyBytes(m int64) optSetter {
 	}
 }
 
-// MaxResponseBodyBytes sets the maximum request body size in bytes
+// MaxResponseBodyBytes sets the maximum response body size in bytes
 func MaxResponseBodyBytes(m int64) optSetter {
 	return func(b *Buffer) error {
 		if m < 0 {
@@ -190,7 +190,7 @@ func MaxResponseBodyBytes(m int64) optSetter {
 	}
 }
 
-// MemResponseBodyBytes sets the maximum request body to be stored in memory
+// MemResponseBodyBytes sets the maximum response body to be stored in memory
 // buffer middleware will serialize the excess to disk.
 func MemResponseBodyBytes(m int64) optSetter {
 	return func(b *Buffer) error {
@@ -216,7 +216,7 @@ func (b *Buffer) ServeHTTP(w http.ResponseWriter, req *http.Request) {
 	}
 
 	if err := b.checkLimit(req); err != nil {
-		log.Errorf("vulcand/oxy/buffer: request body over limit, err: %v", err)
+		b.log.Errorf("vulcand/oxy/buffer: request body over limit, err: %v", err)
 		b.errHandler.ServeHTTP(w, req, err)
 		return
 	}
@@ -234,12 +234,12 @@ func (b *Buffer) ServeHTTP(w http.ResponseWriter, req *http.Request) {
 
 	// Set request body to buffered reader that can replay the read and execute Seek
 	// Note that we don't change the original request body as it's handled by the http server
-	// and we don'w want to mess with standard library
+	// and we don't want to mess with standard library
 	defer func() {
 		if body != nil {
 			errClose := body.Close()
 			if errClose != nil {
-				log.Errorf("vulcand/oxy/buffer: failed to close body, err: %v", errClose)
+				b.log.Errorf("vulcand/oxy/buffer: failed to close body, err: %v", errClose)
 			}
 		}
 	}()
@@ -330,7 +330,7 @@ func (b *Buffer) copyRequest(req *http.Request, body io.ReadCloser, bodySize int
 	o.TransferEncoding = []string{}
 	// http.Transport will close the request body on any error, we are controlling the close process ourselves, so we override the closer here
 	if body == nil {
-		o.Body = nil
+		o.Body = ioutil.NopCloser(req.Body)
 	} else {
 		o.Body = ioutil.NopCloser(body.(io.Reader))
 	}
@@ -383,7 +383,14 @@ func (b *bufferWriter) Header() http.Header {
 }
 
 func (b *bufferWriter) Write(buf []byte) (int, error) {
-	return b.buffer.Write(buf)
+	length, err := b.buffer.Write(buf)
+	if err != nil {
+		// Since go1.11 (https://github.com/golang/go/commit/8f38f28222abccc505b9a1992deecfe3e2cb85de)
+		// if the writer returns an error, the reverse proxy panics
+		b.log.Error(err)
+		length = len(buf)
+	}
+	return length, nil
 }
 
 // WriteHeader sets rw.Code.
@@ -410,7 +417,7 @@ func (b *bufferWriter) Hijack() (net.Conn, *bufio.ReadWriter, error) {
 		return conn, rw, err
 	}
 	b.log.Warningf("Upstream ResponseWriter of type %v does not implement http.Hijacker. Returning dummy channel.", reflect.TypeOf(b.responseWriter))
-	return nil, nil, fmt.Errorf("The response writer that was wrapped in this proxy, does not implement http.Hijacker. It is of type: %v", reflect.TypeOf(b.responseWriter))
+	return nil, nil, fmt.Errorf("the response writer wrapped in this proxy does not implement http.Hijacker. Its type is: %v", reflect.TypeOf(b.responseWriter))
 }
 
 // SizeErrHandler Size error handler
Original file line number	Diff line number	Diff line change
`@@ -179,7 +179,7 @@ func MemRequestBodyBytes(m int64) optSetter {`
`179`	`179`	`}`
`180`	`180`	`}`
`181`	`181`
`182`		`-// MaxResponseBodyBytes sets the maximum request body size in bytes`
	`182`	`+// MaxResponseBodyBytes sets the maximum response body size in bytes`
`183`	`183`	`func MaxResponseBodyBytes(m int64) optSetter {`
`184`	`184`	`return func(b *Buffer) error {`
`185`	`185`	`if m < 0 {`
`@@ -190,7 +190,7 @@ func MaxResponseBodyBytes(m int64) optSetter {`
`190`	`190`	`}`
`191`	`191`	`}`
`192`	`192`
`193`		`-// MemResponseBodyBytes sets the maximum request body to be stored in memory`
	`193`	`+// MemResponseBodyBytes sets the maximum response body to be stored in memory`
`194`	`194`	`// buffer middleware will serialize the excess to disk.`
`195`	`195`	`func MemResponseBodyBytes(m int64) optSetter {`
`196`	`196`	`return func(b *Buffer) error {`
`@@ -216,7 +216,7 @@ func (b Buffer) ServeHTTP(w http.ResponseWriter, req http.Request) {`
`216`	`216`	`}`
`217`	`217`
`218`	`218`	`if err := b.checkLimit(req); err != nil {`
`219`		`- log.Errorf("vulcand/oxy/buffer: request body over limit, err: %v", err)`
	`219`	`+ b.log.Errorf("vulcand/oxy/buffer: request body over limit, err: %v", err)`
`220`	`220`	`b.errHandler.ServeHTTP(w, req, err)`
`221`	`221`	`return`
`222`	`222`	`}`
`@@ -234,12 +234,12 @@ func (b Buffer) ServeHTTP(w http.ResponseWriter, req http.Request) {`
`234`	`234`
`235`	`235`	`// Set request body to buffered reader that can replay the read and execute Seek`
`236`	`236`	`// Note that we don't change the original request body as it's handled by the http server`
`237`		`- // and we don'w want to mess with standard library`
	`237`	`+ // and we don't want to mess with standard library`
`238`	`238`	`defer func() {`
`239`	`239`	`if body != nil {`
`240`	`240`	`errClose := body.Close()`
`241`	`241`	`if errClose != nil {`
`242`		`- log.Errorf("vulcand/oxy/buffer: failed to close body, err: %v", errClose)`
	`242`	`+ b.log.Errorf("vulcand/oxy/buffer: failed to close body, err: %v", errClose)`
`243`	`243`	`}`
`244`	`244`	`}`
`245`	`245`	`}()`
`@@ -330,7 +330,7 @@ func (b Buffer) copyRequest(req http.Request, body io.ReadCloser, bodySize int`
`330`	`330`	`o.TransferEncoding = []string{}`
`331`	`331`	`// http.Transport will close the request body on any error, we are controlling the close process ourselves, so we override the closer here`
`332`	`332`	`if body == nil {`
`333`		`- o.Body = nil`
	`333`	`+ o.Body = ioutil.NopCloser(req.Body)`
`334`	`334`	`} else {`
`335`	`335`	`o.Body = ioutil.NopCloser(body.(io.Reader))`
`336`	`336`	`}`
`@@ -383,7 +383,14 @@ func (b *bufferWriter) Header() http.Header {`
`383`	`383`	`}`
`384`	`384`
`385`	`385`	`func (b *bufferWriter) Write(buf []byte) (int, error) {`
`386`		`- return b.buffer.Write(buf)`
	`386`	`+ length, err := b.buffer.Write(buf)`
	`387`	`+ if err != nil {`
	`388`	`+ // Since go1.11 (https://github.com/golang/go/commit/8f38f28222abccc505b9a1992deecfe3e2cb85de)`
	`389`	`+ // if the writer returns an error, the reverse proxy panics`
	`390`	`+ b.log.Error(err)`
	`391`	`+ length = len(buf)`
	`392`	`+ }`
	`393`	`+ return length, nil`
`387`	`394`	`}`
`388`	`395`
`389`	`396`	`// WriteHeader sets rw.Code.`
`@@ -410,7 +417,7 @@ func (b bufferWriter) Hijack() (net.Conn, bufio.ReadWriter, error) {`
`410`	`417`	`return conn, rw, err`
`411`	`418`	`}`
`412`	`419`	`b.log.Warningf("Upstream ResponseWriter of type %v does not implement http.Hijacker. Returning dummy channel.", reflect.TypeOf(b.responseWriter))`
`413`		`- return nil, nil, fmt.Errorf("The response writer that was wrapped in this proxy, does not implement http.Hijacker. It is of type: %v", reflect.TypeOf(b.responseWriter))`
	`420`	`+ return nil, nil, fmt.Errorf("the response writer wrapped in this proxy does not implement http.Hijacker. Its type is: %v", reflect.TypeOf(b.responseWriter))`
`414`	`421`	`}`
`415`	`422`
`416`	`423`	`// SizeErrHandler Size error handler`