Add queue.max_events to metrics (#37189)

elastic · Nov 24, 2023 · 07f6d5a · 07f6d5a
1 parent 0b22871
commit 07f6d5a
Show file tree

Hide file tree

Showing 5 changed files with 14 additions and 3 deletions.
diff --git a/metricbeat/docs/fields.asciidoc b/metricbeat/docs/fields.asciidoc
@@ -8911,6 +8911,13 @@ type: long
 
 --
 
+*`beat.stats.libbeat.pipeline.queue.max_events`*::
++
+--
+type: long
+
+--
+
 
 *`beat.stats.libbeat.pipeline.events.active`*::
 +

diff --git a/metricbeat/module/beat/fields.go b/metricbeat/module/beat/fields.go
diff --git a/metricbeat/module/beat/stats/_meta/data.json b/metricbeat/module/beat/stats/_meta/data.json
@@ -89,7 +89,8 @@
                         "total": 11
                     },
                     "queue": {
-                        "acked": 0
+                        "acked": 0,
+                        "max_events": 0
                     }
                 }
             },

diff --git a/metricbeat/module/beat/stats/_meta/fields.yml b/metricbeat/module/beat/stats/_meta/fields.yml
@@ -366,6 +366,8 @@
               type: long
             - name: queue.acked
               type: long
+            - name: queue.max_events
+              type: long
             - name: events
               type: group
               fields:

diff --git a/metricbeat/module/beat/stats/data.go b/metricbeat/module/beat/stats/data.go
@@ -75,7 +75,8 @@ var (
 			"pipeline": c.Dict("pipeline", s.Schema{
 				"clients": c.Int("clients"),
 				"queue": c.Dict("queue", s.Schema{
-					"acked": c.Int("acked"),
+					"acked":      c.Int("acked"),
+					"max_events": c.Int("max_events"),
 				}),
 				"events": c.Dict("events", s.Schema{
 					"active":    c.Int("active"),