Enable time units, pct in dashboards

elastic · Nov 25, 2019 · bf3d04f · bf3d04f
1 parent 8eab210
commit bf3d04f
Show file tree

Hide file tree

Showing 10 changed files with 484 additions and 50 deletions.
diff --git a/metricbeat/docs/images/metricbeat-activemq-broker-overview.png b/metricbeat/docs/images/metricbeat-activemq-broker-overview.png
diff --git a/metricbeat/docs/images/metricbeat-activemq-queues-overview.png b/metricbeat/docs/images/metricbeat-activemq-queues-overview.png
diff --git a/metricbeat/docs/images/metricbeat-activemq-topics-overview.png b/metricbeat/docs/images/metricbeat-activemq-topics-overview.png
diff --git a/metricbeat/docs/modules/activemq.asciidoc b/metricbeat/docs/modules/activemq.asciidoc
@@ -35,6 +35,36 @@ metricbeat.modules:
   path: '/api/jolokia/?ignoreErrors=true&canonicalNaming=false'
   username: admin # default username
   password: admin # default password
+  processors:
+    - script:
+        lang: javascript
+        source: >
+          function process(event) {
+            var broker_memory_broker_pct = event.Get("activemq.broker.memory.broker.pct")
+            if (broker_memory_broker_pct != null) {
+              event.Put("activemq.broker.memory.broker.pct", broker_memory_broker_pct / 100.0)
+            }
+
+            var broker_memory_temp_pct = event.Get("activemq.broker.memory.temp.pct")
+            if (broker_memory_temp_pct != null) {
+              event.Put("activemq.broker.memory.temp.pct", broker_memory_temp_pct / 100.0)
+            }
+
+            var broker_memory_store_pct = event.Get("activemq.broker.memory.store.pct")
+            if (broker_memory_store_pct != null) {
+              event.Put("activemq.broker.memory.store.pct", broker_memory_store_pct / 100.0)
+            }
+
+            var queue_memory_broker_pct = event.Get("activemq.queue.memory.broker.pct")
+            if (queue_memory_broker_pct != null) {
+              event.Put("activemq.queue.memory.broker.pct", queue_memory_broker_pct / 100.0)
+            }
+
+            var topic_memory_broker_pct = event.Get("activemq.topic.memory.broker.pct")
+            if (topic_memory_broker_pct != null) {
+              event.Put("activemq.topic.memory.broker.pct", topic_memory_broker_pct / 100.0)
+            }
+          }
 ----
 
 [float]

diff --git a/x-pack/metricbeat/metricbeat.reference.yml b/x-pack/metricbeat/metricbeat.reference.yml
@@ -139,6 +139,36 @@ metricbeat.modules:
   path: '/api/jolokia/?ignoreErrors=true&canonicalNaming=false'
   username: admin # default username
   password: admin # default password
+  processors:
+    - script:
+        lang: javascript
+        source: >
+          function process(event) {
+            var broker_memory_broker_pct = event.Get("activemq.broker.memory.broker.pct")
+            if (broker_memory_broker_pct != null) {
+              event.Put("activemq.broker.memory.broker.pct", broker_memory_broker_pct / 100.0)
+            }
+
+            var broker_memory_temp_pct = event.Get("activemq.broker.memory.temp.pct")
+            if (broker_memory_temp_pct != null) {
+              event.Put("activemq.broker.memory.temp.pct", broker_memory_temp_pct / 100.0)
+            }
+
+            var broker_memory_store_pct = event.Get("activemq.broker.memory.store.pct")
+            if (broker_memory_store_pct != null) {
+              event.Put("activemq.broker.memory.store.pct", broker_memory_store_pct / 100.0)
+            }
+
+            var queue_memory_broker_pct = event.Get("activemq.queue.memory.broker.pct")
+            if (queue_memory_broker_pct != null) {
+              event.Put("activemq.queue.memory.broker.pct", queue_memory_broker_pct / 100.0)
+            }
+
+            var topic_memory_broker_pct = event.Get("activemq.topic.memory.broker.pct")
+            if (topic_memory_broker_pct != null) {
+              event.Put("activemq.topic.memory.broker.pct", topic_memory_broker_pct / 100.0)
+            }
+          }
 
 #------------------------------ Aerospike Module ------------------------------
 - module: aerospike

diff --git a/x-pack/metricbeat/module/activemq/_meta/config.yml b/x-pack/metricbeat/module/activemq/_meta/config.yml
@@ -5,3 +5,33 @@
   path: '/api/jolokia/?ignoreErrors=true&canonicalNaming=false'
   username: admin # default username
   password: admin # default password
+  processors:
+    - script:
+        lang: javascript
+        source: >
+          function process(event) {
+            var broker_memory_broker_pct = event.Get("activemq.broker.memory.broker.pct")
+            if (broker_memory_broker_pct != null) {
+              event.Put("activemq.broker.memory.broker.pct", broker_memory_broker_pct / 100.0)
+            }
+
+            var broker_memory_temp_pct = event.Get("activemq.broker.memory.temp.pct")
+            if (broker_memory_temp_pct != null) {
+              event.Put("activemq.broker.memory.temp.pct", broker_memory_temp_pct / 100.0)
+            }
+
+            var broker_memory_store_pct = event.Get("activemq.broker.memory.store.pct")
+            if (broker_memory_store_pct != null) {
+              event.Put("activemq.broker.memory.store.pct", broker_memory_store_pct / 100.0)
+            }
+
+            var queue_memory_broker_pct = event.Get("activemq.queue.memory.broker.pct")
+            if (queue_memory_broker_pct != null) {
+              event.Put("activemq.queue.memory.broker.pct", queue_memory_broker_pct / 100.0)
+            }
+
+            var topic_memory_broker_pct = event.Get("activemq.topic.memory.broker.pct")
+            if (topic_memory_broker_pct != null) {
+              event.Put("activemq.topic.memory.broker.pct", topic_memory_broker_pct / 100.0)
+            }
+          }