use unsafeBytesToString to reuse memory

bulk_delete_request.go

@@ -179,7 +179,7 @@ func (r *BulkDeleteRequest) Source() ([]string, error) {
 		return nil, err
 	}
 
-	lines := []string{string(body)}
+	lines := []string{unsafeBytesToString(body)}
 	r.source = lines
 
 	return lines, nil

bulk_index_request.go

@@ -231,7 +231,7 @@ func (r *BulkIndexRequest) Source() ([]string, error) {
 		return nil, err
 	}
 
-	lines[0] = string(body)
+	lines[0] = unsafeBytesToString(body)
 
 	// "field1" ...
 	if r.doc != nil {
@@ -241,7 +241,7 @@ func (r *BulkIndexRequest) Source() ([]string, error) {
 			if err != nil {
 				return nil, err
 			}
-			lines[1] = string(body)
+			lines[1] = unsafeBytesToString(body)
 		case json.RawMessage:
 			lines[1] = string(t)
 		case *json.RawMessage:

bulk_update_request.go

@@ -281,7 +281,7 @@ func (r *BulkUpdateRequest) Source() ([]string, error) {
 		return nil, err
 	}
 
-	lines[0] = string(body)
+	lines[0] = unsafeBytesToString(body)
 
 	// 2nd line: {"doc" : { ... }} or {"script": {...}}
 	var doc interface{}
@@ -327,7 +327,7 @@ func (r *BulkUpdateRequest) Source() ([]string, error) {
 		return nil, err
 	}
 
-	lines[1] = string(body)
+	lines[1] = unsafeBytesToString(body)
 
 	r.source = lines
 	return lines, nil

msearch.go

@@ -137,7 +137,7 @@ func (s *MultiSearchService) Do(ctx context.Context) (*MultiSearchResult, error)
 		if err != nil {
 			return nil, err
 		}
-		lines = append(lines, string(header))
+		lines = append(lines, unsafeBytesToString(header))
 		lines = append(lines, body)
 	}
 	body := strings.Join(lines, "\n") + "\n" // add trailing \n

search_request.go

@@ -523,15 +523,15 @@ func (r *SearchRequest) Body() (string, error) {
 		if err != nil {
 			return "", err
 		}
-		return string(body), nil
+		return unsafeBytesToString(body), nil
 	}
 	switch t := r.source.(type) {
 	default:
 		body, err := json.Marshal(r.source)
 		if err != nil {
 			return "", err
 		}
-		return string(body), nil
+		return unsafeBytesToString(body), nil
 	case *SearchSource:
 		src, err := t.Source()
 		if err != nil {
@@ -541,7 +541,7 @@ func (r *SearchRequest) Body() (string, error) {
 		if err != nil {
 			return "", err
 		}
-		return string(body), nil
+		return unsafeBytesToString(body), nil
 	case json.RawMessage:
 		return string(t), nil
 	case *json.RawMessage:

unsafe.go

@@ -0,0 +1,11 @@
+// Copyright 2012-present Oliver Eilhard. All rights reserved.
+// Use of this source code is governed by a MIT-license.
+// See http://olivere.mit-license.org/license.txt for details.
+
+package elastic
+
+import "unsafe"
+
+func unsafeBytesToString(b []byte) string {
+	return *(*string)(unsafe.Pointer(&b))
+}