[1.x] Allow thresholds of slow queries, jobs and requests to be customised by regex pattern

resources/views/livewire/cache.blade.php

@@ -20,7 +20,7 @@
                     Str::plural('group', $count)
                 );
             @endphp
-            <button title="{{ $message }}" @click="alert('{{ str_replace("\n", '\n', $message) }}')">
+            <button title="{{ $message }}" @click="alert(@js($message))">
                 <x-pulse::icons.information-circle class="w-5 h-5 stroke-gray-400 dark:stroke-gray-600" />
             </button>
         </x-slot:actions>

resources/views/livewire/slow-jobs.blade.php

@@ -2,7 +2,7 @@
     <x-pulse::card-header
         name="Slow Jobs"
         title="Time: {{ number_format($time, 0) }}ms; Run at: {{ $runAt }};"
-        details="{{ $config['threshold'] }}ms threshold, past {{ $this->periodForHumans() }}"
+        details="{{ is_array($config['threshold']) ? '' : $config['threshold'].'ms threshold, ' }}past {{ $this->periodForHumans() }}"
     >
         <x-slot:icon>
             <x-pulse::icons.command-line />
@@ -45,6 +45,11 @@
                                 <code class="block text-xs text-gray-900 dark:text-gray-100 truncate" title="{{ $job->job }}">
                                     {{ $job->job }}
                                 </code>
+                                @if (is_array($config['threshold']))
+                                    <p class="mt-1 text-xs text-gray-500 dark:text-gray-400">
+                                        {{ $job->threshold }}ms threshold
+                                    </p>
+                                @endif
                             </x-pulse::td>
                             <x-pulse::td numeric class="text-gray-700 dark:text-gray-300 font-bold">
                                 @if ($config['sample_rate'] < 1)

resources/views/livewire/slow-outgoing-requests.blade.php

@@ -5,7 +5,7 @@
     <x-pulse::card-header
         name="Slow Outgoing Requests"
         title="Time: {{ number_format($time) }}ms; Run at: {{ $runAt }};"
-        details="{{ $config['threshold'] }}ms threshold, past {{ $this->periodForHumans() }}"
+        details="{{ is_array($config['threshold']) ? '' : $config['threshold'].'ms threshold, ' }}past {{ $this->periodForHumans() }}"
     >
         <x-slot:icon>
             <x-pulse::icons.cloud-arrow-up />
@@ -20,7 +20,7 @@
                     Str::plural('group', $count)
                 );
             @endphp
-            <button title="{{ $message }}" @click="alert('{{ str_replace("\n", '\n', $message) }}')">
+            <button title="{{ $message }}" @click="alert(@js($message))">
                 <x-pulse::icons.information-circle class="w-5 h-5 stroke-gray-400 dark:stroke-gray-600" />
             </button>
 
@@ -71,6 +71,11 @@
                                         {{ $request->uri }}
                                     </code>
                                 </div>
+                                @if (is_array($config['threshold']))
+                                    <p class="mt-1 text-xs text-gray-500 dark:text-gray-400">
+                                        {{ $request->threshold }}ms threshold
+                                    </p>
+                                @endif
                             </x-pulse::td>
                             <x-pulse::td numeric class="text-gray-700 dark:text-gray-300 font-bold">
                                 @if ($config['sample_rate'] < 1)

resources/views/livewire/slow-queries.blade.php

@@ -20,7 +20,7 @@
     <x-pulse::card-header
         name="Slow Queries"
         title="Time: {{ number_format($time) }}ms; Run at: {{ $runAt }};"
-        details="{{ $config['threshold'] }}ms threshold, past {{ $this->periodForHumans() }}"
+        details="{{ is_array($config['threshold']) ? '' : $config['threshold'].'ms threshold, ' }}past {{ $this->periodForHumans() }}"
     >
         <x-slot:icon>
             <x-pulse::icons.circle-stack />
@@ -68,6 +68,11 @@
                                                 {{ $query->location }}
                                             </p>
                                         @endif
+                                        @if (is_array($config['threshold']))
+                                            <p class="px-3 mt-3 text-xs leading-none text-gray-400 dark:text-gray-500">
+                                                {{ $query->threshold }}ms threshold
+                                            </p>
+                                        @endif
                                     </div>
                                     <div class="absolute top-0 right-0 bottom-0 rounded-r-md w-3 bg-gradient-to-r from-transparent to-gray-700 dark:to-gray-800 pointer-events-none"></div>
                                 </div>

resources/views/livewire/slow-requests.blade.php

@@ -2,7 +2,7 @@
     <x-pulse::card-header
         name="Slow Requests"
         title="Time: {{ number_format($time) }}ms; Run at: {{ $runAt }};"
-        details="{{ $config['threshold'] }}ms threshold, past {{ $this->periodForHumans() }}"
+        details="{{ is_array($config['threshold']) ? '' : $config['threshold'].'ms threshold, ' }}past {{ $this->periodForHumans() }}"
     >
         <x-slot:icon>
             <x-pulse::icons.arrows-left-right />
@@ -55,6 +55,11 @@
                                         {{ $slowRequest->action }}
                                     </p>
                                 @endif
+                                @if (is_array($config['threshold']))
+                                    <p class="mt-1 text-xs text-gray-500 dark:text-gray-400">
+                                        {{ $slowRequest->threshold }}ms threshold
+                                    </p>
+                                @endif
                             </x-pulse::td>
                             <x-pulse::td numeric class="text-gray-700 dark:text-gray-300 font-bold">
                                 @if ($config['sample_rate'] < 1)

resources/views/livewire/usage.blade.php

@@ -7,7 +7,7 @@
             default => 'Application Usage'
         }"
         title="Time: {{ number_format($time) }}ms; Run at: {{ $runAt }};"
-        details="{{ $this->usage === 'slow_requests' ? ($slowRequestsConfig['threshold'].'ms threshold, ') : '' }}past {{ $this->periodForHumans() }}"
+        details="{{ $this->usage === 'slow_requests' ? (is_array($slowRequestsConfig['threshold']) ? '' : $slowRequestsConfig['threshold'].'ms threshold, ') : '' }}past {{ $this->periodForHumans() }}"
     >
         <x-slot:icon>
             <x-dynamic-component :component="'pulse::icons.' . match ($this->type) {
@@ -31,6 +31,14 @@ class="flex-1"
                     @change="loading = true"
                 />
             @endif
+            @if ($this->usage === 'slow_requests' && is_array($slowRequestsConfig['threshold']))
+                @php
+                    $message = 'You have per-route thresholds configured.';
+                @endphp
+                <button title="{{ $message }}" @click="alert(@js($message))">
+                    <x-pulse::icons.information-circle class="w-5 h-5 stroke-gray-400 dark:stroke-gray-600" />
+                </button>
+            @endif
         </x-slot:actions>
     </x-pulse::card-header>
 

src/Livewire/SlowJobs.php

@@ -5,6 +5,7 @@
 use Illuminate\Contracts\Support\Renderable;
 use Illuminate\Support\Facades\Config;
 use Illuminate\Support\Facades\View;
+use Laravel\Pulse\Recorders\Concerns\Thresholds;
 use Laravel\Pulse\Recorders\SlowJobs as SlowJobsRecorder;
 use Livewire\Attributes\Lazy;
 use Livewire\Attributes\Url;
@@ -15,6 +16,8 @@
 #[Lazy]
 class SlowJobs extends Card
 {
+    use Thresholds;
+
     /**
      * Ordering.
      *
@@ -40,6 +43,7 @@ public function render(): Renderable
                 'job' => $row->key,
                 'slowest' => $row->max,
                 'count' => $row->count,
+                'threshold' => $this->threshold($row->key, SlowJobsRecorder::class),
             ]),
             $this->orderBy,
         );

src/Livewire/SlowOutgoingRequests.php

@@ -5,6 +5,7 @@
 use Illuminate\Contracts\Support\Renderable;
 use Illuminate\Support\Facades\Config;
 use Illuminate\Support\Facades\View;
+use Laravel\Pulse\Recorders\Concerns\Thresholds;
 use Laravel\Pulse\Recorders\SlowOutgoingRequests as SlowOutgoingRequestsRecorder;
 use Livewire\Attributes\Lazy;
 use Livewire\Attributes\Url;
@@ -15,6 +16,8 @@
 #[Lazy]
 class SlowOutgoingRequests extends Card
 {
+    use Thresholds;
+
     /**
      * Ordering.
      *
@@ -44,6 +47,7 @@ public function render(): Renderable
                     'uri' => $uri,
                     'slowest' => $row->max,
                     'count' => $row->count,
+                    'threshold' => $this->threshold($uri, SlowOutgoingRequestsRecorder::class),
                 ];
             }),
             $this->orderBy,

src/Livewire/SlowQueries.php

@@ -5,6 +5,7 @@
 use Illuminate\Contracts\Support\Renderable;
 use Illuminate\Support\Facades\Config;
 use Illuminate\Support\Facades\View;
+use Laravel\Pulse\Recorders\Concerns\Thresholds;
 use Laravel\Pulse\Recorders\SlowQueries as SlowQueriesRecorder;
 use Livewire\Attributes\Lazy;
 use Livewire\Attributes\Url;
@@ -15,6 +16,8 @@
 #[Lazy]
 class SlowQueries extends Card
 {
+    use Thresholds;
+
     /**
      * Ordering.
      *
@@ -56,6 +59,7 @@ public function render(): Renderable
                     'location' => $location,
                     'slowest' => $row->max,
                     'count' => $row->count,
+                    'threshold' => $this->threshold($sql, SlowQueriesRecorder::class),
                 ];
             }),
             $this->orderBy,

src/Livewire/SlowRequests.php

@@ -5,6 +5,7 @@
 use Illuminate\Contracts\Support\Renderable;
 use Illuminate\Support\Facades\Config;
 use Illuminate\Support\Facades\View;
+use Laravel\Pulse\Recorders\Concerns\Thresholds;
 use Laravel\Pulse\Recorders\SlowRequests as SlowRequestsRecorder;
 use Livewire\Attributes\Lazy;
 use Livewire\Attributes\Url;
@@ -15,6 +16,8 @@
 #[Lazy]
 class SlowRequests extends Card
 {
+    use Thresholds;
+
     /**
      * Ordering.
      *
@@ -45,6 +48,7 @@ public function render(): Renderable
                     'action' => $action,
                     'count' => $row->count,
                     'slowest' => $row->max,
+                    'threshold' => $this->threshold($uri, SlowRequestsRecorder::class),
                 ];
             }),
             $this->orderBy,

src/Recorders/Concerns/LivewireRoutes.php

@@ -20,7 +20,7 @@ protected function resolveRoutePath(Request $request): array
         $path = $route->getDomain().Str::start($route->uri(), '/');
         $via = $route->getActionName();
 
-        if ($route->named('*livewire.update')) {
+        if ($route->named('*livewire.update') && $request->has('components.0.snapshot')) {
             $snapshot = json_decode($request->input('components.0.snapshot'), flags: JSON_THROW_ON_ERROR);
 
             if (isset($snapshot->memo->path)) {

src/Recorders/Concerns/Thresholds.php

@@ -2,13 +2,36 @@
 
 namespace Laravel\Pulse\Recorders\Concerns;
 
+use Illuminate\Support\Facades\Config;
+
 trait Thresholds
 {
     /**
      * Determine if the duration is under the configured threshold.
      */
-    protected function underThreshold(int|float $duration): bool
+    protected function underThreshold(int|float $duration, string $value): bool
+    {
+        return $duration < $this->threshold($value);
+    }
+
+    /**
+     * Get the threshold for the given value.
+     */
+    protected function threshold(string $value, ?string $recorder = null): int
     {
-        return $duration < $this->config->get('pulse.recorders.'.static::class.'.threshold');
+        $recorder ??= static::class;
+
+        $config = Config::get("pulse.recorders.{$recorder}.threshold");
+
+        if (! is_array($config)) {
+            return $config;
+        }
+
+        // @phpstan-ignore argument.templateType, argument.templateType
+        $custom = collect($config)
+            ->except(['default'])
+            ->first(fn ($threshold, $pattern) => preg_match($pattern, $value));
+
+        return $custom ?? $config['default'] ?? 1_000;
     }
 }

src/Recorders/SlowJobs.php

@@ -74,9 +74,9 @@ public function record(JobReleasedAfterException|JobFailed|JobProcessed|JobProce
 
         $this->pulse->lazy(function () use ($timestamp, $timestampMs, $name, $lastJobStartedProcessingAt) {
             if (
-                $this->underThreshold($duration = $timestampMs - $lastJobStartedProcessingAt) ||
                 ! $this->shouldSample() ||
-                $this->shouldIgnore($name)
+                $this->shouldIgnore($name) ||
+                $this->underThreshold($duration = $timestampMs - $lastJobStartedProcessingAt, $name)
             ) {
                 return;
             }

src/Recorders/SlowOutgoingRequests.php

@@ -56,9 +56,9 @@ public function record(RequestInterface $request, int $startedAt): void
 
         $this->pulse->lazy(function () use ($startedAt, $timestamp, $endedAt, $method, $uri) {
             if (
-                $this->underThreshold($duration = $endedAt - $startedAt) ||
                 ! $this->shouldSample() ||
-                $this->shouldIgnore($uri)
+                $this->shouldIgnore($uri) ||
+                $this->underThreshold($duration = $endedAt - $startedAt, $uri)
             ) {
                 return;
             }

src/Recorders/SlowQueries.php

@@ -48,9 +48,9 @@ public function record(QueryExecuted $event): void
 
         $this->pulse->lazy(function () use ($timestampMs, $duration, $sql, $location) {
             if (
-                $this->underThreshold($duration) ||
                 ! $this->shouldSample() ||
-                $this->shouldIgnore($sql)
+                $this->shouldIgnore($sql) ||
+                $this->underThreshold($duration, $sql)
             ) {
                 return;
             }

src/Recorders/SlowRequests.php

@@ -50,17 +50,16 @@ public function register(callable $record, Application $app): void
      */
     public function record(Carbon $startedAt, Request $request, Response $response): void
     {
-        if (
-            ! $request->route() instanceof Route ||
-            $this->underThreshold($duration = ((int) $startedAt->diffInMilliseconds())) ||
-            ! $this->shouldSample()
-        ) {
+        if (! $request->route() instanceof Route || ! $this->shouldSample()) {
             return;
         }
 
         [$path, $via] = $this->resolveRoutePath($request);
 
-        if ($this->shouldIgnore($path)) {
+        if (
+            $this->shouldIgnore($path) ||
+            $this->underThreshold($duration = ((int) $startedAt->diffInMilliseconds()), $path)
+        ) {
             return;
         }
 

tests/Feature/Recorders/SlowJobsTest.php

@@ -85,6 +85,37 @@
     expect(Pulse::ignore(fn () => DB::table('pulse_aggregates')->where('type', 'slow_job')->get()))->toHaveCount(0);
 });
 
+it('can configure threshold per job', function () {
+    Carbon::setTestNow('2000-01-02 03:04:05');
+    Config::set('queue.default', 'database');
+    Config::set('pulse.recorders.'.SlowJobs::class.'.threshold', [
+        '#MySlowJob#' => 1_000,
+        '#AnotherSlowJob#' => 2_000,
+    ]);
+
+    Bus::dispatchToQueue(new MySlowJob(1_000));
+    Bus::dispatchToQueue(new AnotherSlowJob(1_000));
+    Artisan::call('queue:work', ['--max-jobs' => 2, '--stop-when-empty' => true, '--sleep' => 0]);
+
+    $entries = Pulse::ignore(fn () => DB::table('pulse_entries')->where('type', 'slow_job')->get());
+    expect($entries)->toHaveCount(1);
+    expect($entries[0]->key)->toBe('MySlowJob');
+    expect($entries[0]->value)->toBe(1_000);
+
+    Pulse::purge();
+
+    Bus::dispatchToQueue(new MySlowJob(2_000));
+    Bus::dispatchToQueue(new AnotherSlowJob(2_000));
+    Artisan::call('queue:work', ['--max-jobs' => 2, '--stop-when-empty' => true, '--sleep' => 0]);
+
+    $entries = Pulse::ignore(fn () => DB::table('pulse_entries')->where('type', 'slow_job')->get());
+    expect($entries)->toHaveCount(2);
+    expect($entries[0]->key)->toBe('MySlowJob');
+    expect($entries[0]->value)->toBe(2_000);
+    expect($entries[1]->key)->toBe('AnotherSlowJob');
+    expect($entries[1]->value)->toBe(2_000);
+});
+
 it('can ignore jobs', function () {
     Config::set('queue.default', 'database');
     Config::set('pulse.recorders.'.SlowJobs::class.'.threshold', 0);
@@ -220,8 +251,18 @@
 
 class MySlowJob implements ShouldQueue
 {
+    public function __construct(public $duration = 100)
+    {
+        //
+    }
+
     public function handle()
     {
-        Carbon::setTestNow(Carbon::now()->addMilliseconds(100));
+        Carbon::setTestNow(Carbon::now()->addMilliseconds($this->duration));
     }
 }
+
+class AnotherSlowJob extends MySlowJob
+{
+    //
+}