diff --git a/collectors/nodestats/nodestats_collector_test.go b/collectors/nodestats/nodestats_collector_test.go
index 67d4495..6468127 100644
--- 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
index 6bf16a1..d4feda0 100644
--- 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
index 4ee321c..ed8b3e1 100644
--- 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