Add state field for connection metricset from RabbitMQ module (#13697) (

#13981)
elastic · Nov 4, 2019 · fd1be61 · fd1be61
1 parent 49a37a9
commit fd1be61
Show file tree

Hide file tree

Showing 6 changed files with 19 additions and 1 deletion.
diff --git a/metricbeat/docs/fields.asciidoc b/metricbeat/docs/fields.asciidoc
@@ -26116,6 +26116,16 @@ alias to: rabbitmq.node.name
 
 --
 
+*`rabbitmq.connection.state`*::
++
+--
+Connection state.
+
+
+type: keyword
+
+--
+
 *`rabbitmq.connection.channels`*::
 +
 --

diff --git a/metricbeat/module/rabbitmq/connection/_meta/data.json b/metricbeat/module/rabbitmq/connection/_meta/data.json
@@ -33,6 +33,7 @@
                 "port": 60940
             },
             "port": 5672,
+            "state": "running",
             "type": "network"
         },
         "node": {

diff --git a/metricbeat/module/rabbitmq/connection/_meta/fields.yml b/metricbeat/module/rabbitmq/connection/_meta/fields.yml
@@ -26,6 +26,10 @@
       migration: true
       description: >
         Node name.
+    - name: state
+      type: keyword
+      description: >
+        Connection state.
     - name: channels
       type: long
       description: >

diff --git a/metricbeat/module/rabbitmq/connection/_meta/testdata/docs.json-expected.json b/metricbeat/module/rabbitmq/connection/_meta/testdata/docs.json-expected.json
@@ -33,6 +33,7 @@
                     "port": 60940
                 },
                 "port": 5672,
+                "state": "running",
                 "type": "network"
             },
             "node": {
@@ -82,6 +83,7 @@
                     "port": 60938
                 },
                 "port": 5672,
+                "state": "running",
                 "type": "network"
             },
             "node": {

diff --git a/metricbeat/module/rabbitmq/connection/data.go b/metricbeat/module/rabbitmq/connection/data.go
@@ -37,6 +37,7 @@ var (
 		"vhost":       c.Str("vhost", s.Required),
 		"user":        c.Str("user", s.Required),
 		"node":        c.Str("node", s.Required),
+		"state":       c.Str("state"),
 		"channels":    c.Int("channels"),
 		"channel_max": c.Int("channel_max"),
 		"frame_max":   c.Int("frame_max"),

diff --git a/metricbeat/module/rabbitmq/fields.go b/metricbeat/module/rabbitmq/fields.go