Examples: Update the "valyala/fasthttp" example to send HTTP body as POST

Related: #112

(cherry picked from commit ca6559d)

Author: karmi

_examples/fasthttp/cmd/main.go

@@ -5,10 +5,12 @@
 package main
 
 import (
+	"context"
 	"log"
 	"os"
 	"sort"
 	"strconv"
+	"strings"
 	"time"
 
 	"github.com/elastic/go-elasticsearch/v7"
@@ -42,6 +44,31 @@ func main() {
 		log.Fatalf("Error creating the client: %s", err)
 	}
 
+	// Test sending the body as POST
+	//
+	ctx, cancel := context.WithTimeout(context.Background(), 500*time.Millisecond)
+	defer cancel()
+
+	go func() {
+		es.Info()
+		if _, err := es.Search(
+			es.Search.WithBody(strings.NewReader(`{"query":{"match":{"title":"foo"}}}`)),
+			es.Search.WithPretty(),
+		); err != nil {
+			log.Fatalf("Error getting response: %s", err)
+		}
+		cancel()
+	}()
+
+	select {
+	case <-ctx.Done():
+		if ctx.Err() != context.Canceled {
+			log.Fatalf("Timeout: %s", ctx.Err())
+		}
+	}
+
+	// Run benchmark
+	//
 	t := time.Now()
 	for i := 0; i < count; i++ {
 		t0 := time.Now()

_examples/fasthttp/fasthttp.go

@@ -42,6 +42,10 @@ func (t *Transport) RoundTrip(req *http.Request) (*http.Response, error) {
 // copyRequest converts a http.Request to fasthttp.Request
 //
 func (t *Transport) copyRequest(dst *fasthttp.Request, src *http.Request) *fasthttp.Request {
+	if src.Method == "GET" && src.Body != nil {
+		src.Method = "POST"
+	}
+
 	dst.SetHost(src.Host)
 	dst.SetRequestURI(src.URL.String())
 

_examples/fasthttp/go.mod

@@ -5,6 +5,6 @@ go 1.11
 replace github.com/elastic/go-elasticsearch/v7 => ../..
 
 require (
-	github.com/elastic/go-elasticsearch/v7 v7.0.0-20190407092644-3fb2a278216b
+	github.com/elastic/go-elasticsearch/v7 7.x
 	github.com/valyala/fasthttp v1.5.0
 )