Rabbitmq exchanges metricset

CHANGELOG.asciidoc

@@ -256,6 +256,7 @@ https://github.com/elastic/beats/compare/v6.0.0-beta2...master[Check the HEAD di
 - Making the MongoDB module GA. {pull}6554[6554]
 - Allow to disable labels `dedot` in Docker module, in favor of a safe way to keep dots. {pull}6490[6490]
 - Add experimental module to collect metrics from munin nodes. {pull}6517[6517]
+- Add exchanges metricset to the RabbitMQ module {issue}6442[6442] {pull}6607[6607]
 
 *Packetbeat*
 

metricbeat/docs/fields.asciidoc

@@ -8818,6 +8818,181 @@ type: long
 Number of octets received on the connection.
 
 
+[float]
+== exchange fields
+
+exchange
+
+
+
+[float]
+=== `rabbitmq.exchange.name`
+
+type: keyword
+
+The name of the queue with non-ASCII characters escaped as in C.
+
+
+[float]
+=== `rabbitmq.exchange.vhost`
+
+type: keyword
+
+Virtual host name with non-ASCII characters escaped as in C.
+
+
+[float]
+=== `rabbitmq.exchange.durable`
+
+type: boolean
+
+Whether or not the queue survives server restarts.
+
+
+[float]
+=== `rabbitmq.exchange.auto_delete`
+
+type: boolean
+
+Whether the queue will be deleted automatically when no longer used.
+
+
+[float]
+=== `rabbitmq.exchange.internal`
+
+type: boolean
+
+Whether the exchange is internal, i.e. cannot be directly published to by a client.
+
+
+[float]
+=== `rabbitmq.exchange.messages.publish.count`
+
+type: long
+
+Count of messages published.
+
+
+[float]
+=== `rabbitmq.exchange.messages.publish.details.rate`
+
+type: float
+
+How much the exchange publish count has changed per second in the most recent sampling interval.
+
+
+[float]
+=== `rabbitmq.exchange.messages.publish_in.count`
+
+type: long
+
+Count of messages published "in" to an exchange, i.e. not taking account of routing.
+
+
+[float]
+=== `rabbitmq.exchange.messages.publish_in.details.rate`
+
+type: float
+
+How much the exchange publish-in count has changed per second in the most recent sampling interval.
+
+
+[float]
+=== `rabbitmq.exchange.messages.publish_out.count`
+
+type: long
+
+Count of messages published "out" of an exchange, i.e. taking account of routing.
+
+
+[float]
+=== `rabbitmq.exchange.messages.publish_out.details.rate`
+
+type: float
+
+How much the exchange publish-out count has changed per second in the most recent sampling interval.
+
+
+[float]
+=== `rabbitmq.exchange.messages.ack.count`
+
+type: long
+
+Count of acknowledged messages.
+
+
+[float]
+=== `rabbitmq.exchange.messages.ack.details.rate`
+
+type: float
+
+How much the exchange ack count has changed per second in the most recent sampling interval.
+
+
+[float]
+=== `rabbitmq.exchange.messages.deliver_get.count`
+
+type: long
+
+Count of all messages delivered to consumers.
+
+
+[float]
+=== `rabbitmq.exchange.messages.deliver_get.details.rate`
+
+type: float
+
+How much the exchange deliver-get count has changed per second in the most recent sampling interval.
+
+
+[float]
+=== `rabbitmq.exchange.messages.confirm.count`
+
+type: long
+
+Count of messages confirmed.
+
+
+[float]
+=== `rabbitmq.exchange.messages.confirm.details.rate`
+
+type: float
+
+How much the exchange confirm count has changed per second in the most recent sampling interval.
+
+
+[float]
+=== `rabbitmq.exchange.messages.return_unroutable.count`
+
+type: long
+
+Count of messages returned to publisher as unroutable.
+
+
+[float]
+=== `rabbitmq.exchange.messages.return_unroutable.details.rate`
+
+type: float
+
+How much the exchange return-unroutable count has changed per second in the most recent sampling interval.
+
+
+[float]
+=== `rabbitmq.exchange.messages.redeliver.count`
+
+type: long
+
+Count of subset of messages in deliver_get which had the redelivered flag set.
+
+
+[float]
+=== `rabbitmq.exchange.messages.redeliver.details.rate`
+
+type: float
+
+How much the exchange redeliver count has changed per second in the most recent sampling interval.
+
+
 [float]
 == node fields
 

metricbeat/docs/modules/rabbitmq.asciidoc

@@ -21,7 +21,7 @@ in <<configuration-metricbeat>>. Here is an example configuration:
 ----
 metricbeat.modules:
 - module: rabbitmq
-  metricsets: ["node", "queue", "connection"]
+  metricsets: ["node", "queue", "connection", "exchange"]
   period: 10s
   hosts: ["localhost:15672"]
 
@@ -38,12 +38,16 @@ The following metricsets are available:
 
 * <<metricbeat-metricset-rabbitmq-connection,connection>>
 
+* <<metricbeat-metricset-rabbitmq-exchange,exchange>>
+
 * <<metricbeat-metricset-rabbitmq-node,node>>
 
 * <<metricbeat-metricset-rabbitmq-queue,queue>>
 
 include::rabbitmq/connection.asciidoc[]
 
+include::rabbitmq/exchange.asciidoc[]
+
 include::rabbitmq/node.asciidoc[]
 
 include::rabbitmq/queue.asciidoc[]

metricbeat/docs/modules/rabbitmq/exchange.asciidoc

@@ -0,0 +1,23 @@
+////
+This file is generated! See scripts/docs_collector.py
+////
+
+[[metricbeat-metricset-rabbitmq-exchange]]
+=== RabbitMQ exchange metricset
+
+beta[]
+
+include::../../../module/rabbitmq/exchange/_meta/docs.asciidoc[]
+
+
+==== Fields
+
+For a description of each field in the metricset, see the
+<<exported-fields-rabbitmq,exported fields>> section.
+
+Here is an example document generated by this metricset:
+
+[source,json]
+----
+include::../../../module/rabbitmq/exchange/_meta/data.json[]
+----

metricbeat/docs/modules_list.asciidoc

@@ -95,7 +95,8 @@ This file is generated! See scripts/docs_collector.py
 .2+|   |<<metricbeat-metricset-prometheus-collector,collector>> beta[]  
 |<<metricbeat-metricset-prometheus-stats,stats>> beta[]  
 |<<metricbeat-module-rabbitmq,RabbitMQ>>  beta[]   |    
-.3+|   |<<metricbeat-metricset-rabbitmq-connection,connection>> beta[]  
+.4+|   |<<metricbeat-metricset-rabbitmq-connection,connection>> beta[]  
+|<<metricbeat-metricset-rabbitmq-exchange,exchange>> beta[]  
 |<<metricbeat-metricset-rabbitmq-node,node>> beta[]  
 |<<metricbeat-metricset-rabbitmq-queue,queue>> beta[]  
 |<<metricbeat-module-redis,Redis>>     |    

metricbeat/include/list.go

@@ -100,6 +100,7 @@ import (
 	_ "github.com/elastic/beats/metricbeat/module/prometheus/stats"
 	_ "github.com/elastic/beats/metricbeat/module/rabbitmq"
 	_ "github.com/elastic/beats/metricbeat/module/rabbitmq/connection"
+	_ "github.com/elastic/beats/metricbeat/module/rabbitmq/exchange"
 	_ "github.com/elastic/beats/metricbeat/module/rabbitmq/node"
 	_ "github.com/elastic/beats/metricbeat/module/rabbitmq/queue"
 	_ "github.com/elastic/beats/metricbeat/module/redis"

metricbeat/metricbeat.reference.yml

@@ -431,7 +431,7 @@ metricbeat.modules:
 
 #------------------------------ RabbitMQ Module ------------------------------
 - module: rabbitmq
-  metricsets: ["node", "queue", "connection"]
+  metricsets: ["node", "queue", "connection", "exchange"]
   period: 10s
   hosts: ["localhost:15672"]
 

metricbeat/module/rabbitmq/_meta/config.yml

@@ -1,5 +1,5 @@
 - module: rabbitmq
-  metricsets: ["node", "queue", "connection"]
+  metricsets: ["node", "queue", "connection", "exchange"]
   period: 10s
   hosts: ["localhost:15672"]
 

metricbeat/module/rabbitmq/_meta/testdata/exchange_sample_response.json

@@ -0,0 +1,45 @@
+[
+    {
+        "message_stats": {
+            "publish": 123,
+            "publish_details": {
+                "rate": 0.1
+            },
+            "publish_in": 100,
+            "publish_in_details": {
+                "rate": 0.5
+            },
+            "publish_out": 99,
+            "publish_out_details": {
+                "rate": 0.9
+            },
+            "ack": 60,
+            "ack_details": {
+                "rate": 12.5
+            },
+            "deliver_get": 50,
+            "deliver_get_details": {
+                "rate": 43.21
+            },
+            "confirm": 120,
+            "confirm_details": {
+                "rate": 98.63
+            },
+            "return_unroutable": 40,
+            "return_unroutable_details": {
+                "rate": 123
+            },
+            "redeliver": 30,
+            "redeliver_details": {
+                "rate": 0
+            }
+        },
+        "name": "exchange.name",
+        "vhost": "/",
+        "type": "fanout",
+        "durable": true,
+        "auto_delete": false,
+        "internal": false,
+        "arguments": {}
+    }
+]

metricbeat/module/rabbitmq/exchange/_meta/data.json

@@ -0,0 +1,19 @@
+{
+    "@timestamp":"2016-05-23T08:05:34.853Z",
+    "beat":{
+        "hostname":"beathost",
+        "name":"beathost"
+    },
+    "metricset":{
+        "host":"localhost",
+        "module":"rabbitmq",
+        "name":"exchange",
+        "rtt":44269
+    },
+    "rabbitmq":{
+        "exchange":{
+            "example": "exchange"
+        }
+    },
+    "type":"metricsets"
+}

metricbeat/module/rabbitmq/exchange/_meta/docs.asciidoc

@@ -0,0 +1,3 @@
+=== rabbitmq exchange MetricSet
+
+This is the exchange metricset of the module rabbitmq.