93: Adds logstash_stats_pipeline_up metrics

kuskoman · Apr 26, 2023 · 3627bec · 3627bec
1 parent 4ec0b0f
commit 3627bec
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 0 deletions.
diff --git a/collectors/nodestats/nodestats_collector_test.go b/collectors/nodestats/nodestats_collector_test.go
@@ -67,6 +67,7 @@ func TestCollectNotNil(t *testing.T) {
 		"logstash_stats_jvm_threads_count",
 		"logstash_stats_jvm_threads_peak_count",
 		"logstash_stats_jvm_uptime_millis",
+		"logstash_stats_pipeline_up",
 		"logstash_stats_pipeline_events_duration",
 		"logstash_stats_pipeline_events_filtered",
 		"logstash_stats_pipeline_events_in",

diff --git a/collectors/nodestats/pipeline_subcollector.go b/collectors/nodestats/pipeline_subcollector.go
@@ -64,6 +64,8 @@ func (collector *PipelineSubcollector) Collect(pipeStats *responses.SinglePipeli
 	ch <- prometheus.MustNewConstMetric(collector.EventsDuration, prometheus.CounterValue, float64(pipeStats.Events.DurationInMillis), pipelineID)
 	ch <- prometheus.MustNewConstMetric(collector.EventsQueuePushDuration, prometheus.CounterValue, float64(pipeStats.Events.QueuePushDurationInMillis), pipelineID)
 
+	ch <- prometheus.MustNewConstMetric(collector.Up, prometheus.GaugeValue, float64(collector.isPipelineHealthy(pipeStats.Reloads)), pipelineID)
+
 	ch <- prometheus.MustNewConstMetric(collector.ReloadsSuccesses, prometheus.CounterValue, float64(pipeStats.Reloads.Successes), pipelineID)
 	ch <- prometheus.MustNewConstMetric(collector.ReloadsFailures, prometheus.CounterValue, float64(pipeStats.Reloads.Failures), pipelineID)
 

diff --git a/scripts/snapshots/metric_names.txt b/scripts/snapshots/metric_names.txt
@@ -14,6 +14,7 @@ logstash_stats_jvm_mem_non_heap_committed_bytes
 logstash_stats_jvm_threads_count
 logstash_stats_jvm_threads_peak_count
 logstash_stats_jvm_uptime_millis
+logstash_stats_pipeline_up
 logstash_stats_pipeline_events_duration
 logstash_stats_pipeline_events_filtered
 logstash_stats_pipeline_events_in