Add HTTP status phrase in reponse for metricsbeat http module (#5470) (…

…#5484)
elastic · Nov 8, 2017 · a5c9c5e · a5c9c5e
1 parent 3eb68bf
commit a5c9c5e
Show file tree

Hide file tree

Showing 4 changed files with 19 additions and 1 deletion.
diff --git a/metricbeat/docs/fields.asciidoc b/metricbeat/docs/fields.asciidoc
@@ -4442,6 +4442,16 @@ type: keyword
 The HTTP status code
 
 
+[float]
+=== `http.response.phrase`
+
+type: keyword
+
+example: Not found
+
+The HTTP status phrase
+
+
 [float]
 === `http.response.body`
 

diff --git a/metricbeat/module/http/_meta/fields.yml b/metricbeat/module/http/_meta/fields.yml
@@ -37,6 +37,11 @@
               type: keyword
               description: >
                 The HTTP status code
+            - name: phrase
+              type: keyword
+              example: Not found
+              description: >
+                The HTTP status phrase
             - name: body
               type: keyword
               description: >

diff --git a/metricbeat/module/http/_meta/test/main.go b/metricbeat/module/http/_meta/test/main.go
@@ -15,5 +15,5 @@ func main() {
 }
 
 func serve(w http.ResponseWriter, r *http.Request) {
-	fmt.Fprintf(w, `{"hello":"world"}`)
+	fmt.Fprint(w, `{"hello":"world"}`)
 }
diff --git a/metricbeat/module/http/json/json.go b/metricbeat/module/http/json/json.go
@@ -4,6 +4,7 @@ import (
 	"encoding/json"
 	"io/ioutil"
 	"net/http"
+	"strconv"
 	"strings"
 
 	"github.com/elastic/beats/libbeat/common"
@@ -124,9 +125,11 @@ func (m *MetricSet) Fetch() (common.MapStr, error) {
 	}
 
 	if m.responseEnabled {
+		phrase := strings.TrimPrefix(response.Status, strconv.Itoa(response.StatusCode)+" ")
 		event[mb.ModuleDataKey] = common.MapStr{
 			"response": common.MapStr{
 				"status_code": response.StatusCode,
+				"phrase":      phrase,
 				"headers":     m.getHeaders(response.Header),
 			},
 		}