Add horizon:reset-metrics command (#1318)

* Add reset-metric artisan command

* Be more specific to only delete the lock key

* Update ResetMetricsCommand.php

* Update RedisMetricsRepository.php

* formatting

* formatting

---------

Co-authored-by: Taylor Otwell <taylor@laravel.com>

src/Console/ClearMetricsCommand.php

@@ -0,0 +1,36 @@
+<?php
+
+namespace Laravel\Horizon\Console;
+
+use Illuminate\Console\Command;
+use Laravel\Horizon\Contracts\MetricsRepository;
+
+class ClearMetricsCommand extends Command
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'horizon:clear-metrics';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = 'Delete metrics for all jobs and queues';
+
+    /**
+     * Execute the console command.
+     *
+     * @param  \Laravel\Horizon\Contracts\MetricsRepository  $metrics
+     * @return void
+     */
+    public function handle(MetricsRepository $metrics)
+    {
+        $metrics->reset();
+
+        $this->info('Metrics cleared successfully.');
+    }
+}

src/Contracts/MetricsRepository.php

@@ -133,4 +133,11 @@ public function acquireWaitTimeMonitorLock();
      * @return void
      */
     public function forget($key);
+
+    /**
+     * Delete all stored metrics information.
+     *
+     * @return void
+     */
+    public function clear();
 }

src/HorizonServiceProvider.php

@@ -110,6 +110,7 @@ protected function registerCommands()
         if ($this->app->runningInConsole()) {
             $this->commands([
                 Console\ClearCommand::class,
+                Console\ClearMetricsCommand::class,
                 Console\ContinueCommand::class,
                 Console\ContinueSupervisorCommand::class,
                 Console\ForgetFailedCommand::class,

src/Repositories/RedisMetricsRepository.php

@@ -4,6 +4,7 @@
 
 use Carbon\CarbonImmutable;
 use Illuminate\Contracts\Redis\Factory as RedisFactory;
+use Illuminate\Support\Str;
 use Laravel\Horizon\Contracts\MetricsRepository;
 use Laravel\Horizon\Lock;
 use Laravel\Horizon\LuaScripts;
@@ -372,6 +373,33 @@ public function forget($key)
         $this->connection()->del($key);
     }
 
+    /**
+     * Delete all stored metrics information.
+     *
+     * @return void
+     */
+    public function clear()
+    {
+        $this->forget('last_snapshot_at');
+        $this->forget('measured_jobs');
+        $this->forget('measured_queues');
+        $this->forget('metrics:snapshot');
+
+        foreach (['queue:*', 'job:*', 'snapshot:*'] as $pattern) {
+            $cursor = null;
+
+            do {
+                [$cursor, $keys] = $this->connection()->scan(
+                    $cursor, ['match' => config('horizon.prefix').$pattern]
+                );
+
+                foreach ($keys as $key) {
+                    $this->forget(Str::after($key, config('horizon.prefix')));
+                }
+            } while ($cursor > 0);
+        }
+    }
+
     /**
      * Get the Redis connection instance.
      *