Fixed stream message rate on jetstream dashboards

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
nats-io · Jan 26, 2024 · 84dde2a · 84dde2a
1 parent 861732f
commit 84dde2a
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/collector/jsz.go b/collector/jsz.go
@@ -91,7 +91,7 @@ func newJszCollector(system, endpoint string, servers []*CollectedServer) promet
 			serverLabels,
 			nil,
 		),
-		// jetstream_stream_total_messages
+		// jetstream_server_total_streams
 		streams: prometheus.NewDesc(
 			prometheus.BuildFQName(system, "server", "total_streams"),
 			"Total number of streams in JetStream",
@@ -147,14 +147,14 @@ func newJszCollector(system, endpoint string, servers []*CollectedServer) promet
 			streamLabels,
 			nil,
 		),
-		// jetstream_stream_state_first_seq
+		// jetstream_stream_first_seq
 		streamFirstSeq: prometheus.NewDesc(
 			prometheus.BuildFQName(system, "stream", "first_seq"),
 			"First sequence from a stream",
 			streamLabels,
 			nil,
 		),
-		// jetstream_stream_state_last_seq
+		// jetstream_stream_last_seq
 		streamLastSeq: prometheus.NewDesc(
 			prometheus.BuildFQName(system, "stream", "last_seq"),
 			"Last sequence from a stream",

diff --git a/walkthrough/grafana-jetstream-dash-helm.json b/walkthrough/grafana-jetstream-dash-helm.json
@@ -760,7 +760,7 @@
       "pluginVersion": "8.3.4",
       "targets": [
         {
-          "expr": "sum(rate(nats_stream_total_messages{server_id=~\"$server\",stream_name=~\"$stream\"}[$__rate_interval])) by (stream_name)",
+          "expr": "sum(rate(nats_stream_last_seq{server_id=~\"$server\",stream_name=~\"$stream\"}[$__rate_interval])) by (stream_name)",
           "hide": false,
           "interval": "",
           "legendFormat": "{{stream_name}}",

diff --git a/walkthrough/grafana-jetstream-dash.json b/walkthrough/grafana-jetstream-dash.json
@@ -760,7 +760,7 @@
       "pluginVersion": "8.3.4",
       "targets": [
         {
-          "expr": "sum(rate(jetstream_stream_total_messages{server_id=~\"$server\",stream_name=~\"$stream\"}[$__rate_interval])) by (stream_name)",
+          "expr": "sum(rate(jetstream_stream_last_seq{server_id=~\"$server\",stream_name=~\"$stream\"}[$__rate_interval])) by (stream_name)",
           "hide": false,
           "interval": "",
           "legendFormat": "{{stream_name}}",