From dacaa08e78743e8455ced4f48f2d3c7afb68d570 Mon Sep 17 00:00:00 2001 From: Vijay Samuel Date: Mon, 6 Aug 2018 23:26:24 -0700 Subject: [PATCH] Add missing namespace field in http server metricset --- CHANGELOG.asciidoc | 1 + metricbeat/module/http/server/server.go | 14 +++++++++----- 2 files changed, 10 insertions(+), 5 deletions(-) diff --git a/CHANGELOG.asciidoc b/CHANGELOG.asciidoc index 1bfac30203e..f00651a5c32 100644 --- a/CHANGELOG.asciidoc +++ b/CHANGELOG.asciidoc @@ -46,6 +46,7 @@ https://github.com/elastic/beats/compare/v6.4.0...master[Check the HEAD diff] - Fix golang.heap.gc.cpu_fraction type from long to float in Golang module. {pull}7789[7789] - Fixed a panic when the kvm module cannot establish a connection to libvirtd. {issue}7792[7792]. +- Add missing namespace field in http server metricset {pull}7890[7890] *Packetbeat* diff --git a/metricbeat/module/http/server/server.go b/metricbeat/module/http/server/server.go index 283ba1d583f..492e92bbcb3 100644 --- a/metricbeat/module/http/server/server.go +++ b/metricbeat/module/http/server/server.go @@ -18,7 +18,8 @@ package server import ( - "github.com/elastic/beats/libbeat/common" + "fmt" + "github.com/elastic/beats/libbeat/common/cfgwarn" serverhelper "github.com/elastic/beats/metricbeat/helper/server" "github.com/elastic/beats/metricbeat/helper/server/http" @@ -83,10 +84,13 @@ func (m *MetricSet) Run(reporter mb.PushReporterV2) { reporter.Error(err) } else { event := mb.Event{} - event.ModuleFields = common.MapStr{} - metricSetName := fields[mb.NamespaceKey].(string) - delete(fields, mb.NamespaceKey) - event.ModuleFields.Put(metricSetName, fields) + ns, ok := fields[mb.NamespaceKey].(string) + if ok { + ns = fmt.Sprintf("http.%s", ns) + delete(fields, mb.NamespaceKey) + } + event.MetricSetFields = fields + event.Namespace = ns reporter.Event(event) }