add horizon collectors

resources/stubs/PrometheusServiceProvider.php.stub

@@ -7,6 +7,9 @@ use Spatie\Prometheus\Collectors\Horizon\CurrentMasterSupervisorCollector;
 use Spatie\Prometheus\Collectors\Horizon\CurrentProcessesPerQueueCollector;
 use Spatie\Prometheus\Collectors\Horizon\CurrentWorkloadCollector;
 use Spatie\Prometheus\Collectors\Horizon\FailedJobsPerHourCollector;
+use Spatie\Prometheus\Collectors\Horizon\HorizonStatusCollector;
+use Spatie\Prometheus\Collectors\Horizon\JobsPerMinuteCollector;
+use Spatie\Prometheus\Collectors\Horizon\RecentJobsCollector;
 use Spatie\Prometheus\Facades\Prometheus;
 
 class PrometheusServiceProvider extends ServiceProvider
@@ -35,6 +38,9 @@ class PrometheusServiceProvider extends ServiceProvider
             CurrentProcessesPerQueueCollector::class,
             CurrentWorkloadCollector::class,
             FailedJobsPerHourCollector::class,
+            HorizonStatusCollector::class,
+            JobsPerMinuteCollector::class,
+            RecentJobsCollector::class,
         ]);
 
         return $this;

src/Collectors/Horizon/HorizonStatusCollector.php

@@ -2,12 +2,32 @@
 
 namespace Spatie\Prometheus\Collectors\Horizon;
 
+use Laravel\Horizon\Contracts\MasterSupervisorRepository;
 use Spatie\Prometheus\Collectors\Collector;
+use Spatie\Prometheus\Facades\Prometheus;
 
 class HorizonStatusCollector implements Collector
 {
+    protected const INACTIVE = -1;
+    protected const PAUSED = 0;
+    protected const RUNNING = 1;
+
+
     public function register(): void
     {
-        // TODO: Implement register() method.
+        Prometheus::addGauge('Horizon status')
+            ->helpText('The status of Horizon, -1 = inactive, 0 = paused, 1 = running')
+            ->value(function () {
+                if (!$masters = app(MasterSupervisorRepository::class)->all()) {
+                    return self::INACTIVE;
+                }
+
+                $isPaused = collect($masters)
+                    ->contains(fn($master) => $master->status === 'paused');
+
+                return $isPaused
+                    ? self::PAUSED
+                    : self::RUNNING;
+            });
     }
 }

src/Collectors/Horizon/JobsPerMinuteCollector.php

@@ -0,0 +1,17 @@
+<?php
+
+namespace Spatie\Prometheus\Collectors\Horizon;
+
+use Laravel\Horizon\Contracts\MetricsRepository;
+use Spatie\Prometheus\Collectors\Collector;
+use Spatie\Prometheus\Facades\Prometheus;
+
+class JobsPerMinuteCollector implements Collector
+{
+    public function register(): void
+    {
+        Prometheus::addGauge('jobs per minute')
+            ->helpText('The number of jobs per minute')
+            ->value(fn() => app(MetricsRepository::class)->jobsProcessedPerMinute());
+    }
+}

src/Collectors/Horizon/RecentJobsCollector.php

@@ -0,0 +1,17 @@
+<?php
+
+namespace Spatie\Prometheus\Collectors\Horizon;
+
+use Laravel\Horizon\Contracts\JobRepository;
+use Spatie\Prometheus\Collectors\Collector;
+use Spatie\Prometheus\Facades\Prometheus;
+
+class RecentJobsCollector implements Collector
+{
+    public function register(): void
+    {
+        Prometheus::addGauge('Recent jobs')
+            ->helpText('The number of recent jobs')
+            ->value(fn() => app(JobRepository::class)->countRecent());
+    }
+}

tests/Collectors/Horizon/HorizonStatusCollectorTest.php

@@ -0,0 +1,9 @@
+<?php
+
+use Spatie\Prometheus\Collectors\Horizon\HorizonStatusCollector;
+
+it('can register the horizon status collector', function () {
+    app(HorizonStatusCollector::class)->register();
+
+    assertPrometheusResultsMatchesSnapshot();
+});

tests/Collectors/Horizon/JobsPerMinuteCollectorTest.php

@@ -0,0 +1,9 @@
+<?php
+
+use Spatie\Prometheus\Collectors\Horizon\JobsPerMinuteCollector;
+
+it('can register the jobs per minute collector', function () {
+    app(JobsPerMinuteCollector::class)->register();
+
+    assertPrometheusResultsMatchesSnapshot();
+});

tests/Collectors/Horizon/RecentJobsCollectorTest.php

@@ -0,0 +1,9 @@
+<?php
+
+use Spatie\Prometheus\Collectors\Horizon\RecentJobsCollector;
+
+it('can register the recent jobs collector', function () {
+    app(RecentJobsCollector::class)->register();
+
+    assertPrometheusResultsMatchesSnapshot();
+});

tests/__snapshots__/HorizonStatusCollectorTest__it_can_register_the_horizon_status_collector__1.txt

@@ -0,0 +1,6 @@
+# HELP app_horizon_status The status of Horizon, -1 = inactive, 0 = paused, 1 = running
+# TYPE app_horizon_status gauge
+app_horizon_status -1
+# HELP php_info Information about the PHP environment.
+# TYPE php_info gauge
+php_info{version="8.2.0"} 1

tests/__snapshots__/JobsPerMinuteCollectorTest__it_can_register_the_jobs_per_minute_collector__1.txt

@@ -0,0 +1,6 @@
+# HELP app_jobs_per_minute The number of jobs per minute
+# TYPE app_jobs_per_minute gauge
+app_jobs_per_minute 0
+# HELP php_info Information about the PHP environment.
+# TYPE php_info gauge
+php_info{version="8.2.0"} 1

tests/__snapshots__/RecentJobsCollectorTest__it_can_register_the_recent_jobs_collector__1.txt

@@ -0,0 +1,6 @@
+# HELP app_recent_jobs The number of recent jobs
+# TYPE app_recent_jobs gauge
+app_recent_jobs 0
+# HELP php_info Information about the PHP environment.
+# TYPE php_info gauge
+php_info{version="8.2.0"} 1