implement job throttling

app/AgentScheduler.php

@@ -3,12 +3,13 @@
 namespace App;
 
 use App\Jobs\RunAgent;
-
+use App\Server;
 use App\Sensor\StatusChangeDetector;
 
 use Illuminate\Support\Facades\File;
 use Illuminate\Support\LazyCollection;
 use Illuminate\Support\Collection;
+use Illuminate\Support\Facades\Queue;
 use Symfony\Component\Finder\SplFileInfo;
 
 /**
@@ -110,10 +111,19 @@ class AgentScheduler
         })->toArray();
     }
 
+    public function throttlingTreshold() : int
+    {
+        return max(2, Server::count()) * 2 *  $this->sensors()->count();
+    }
+
     // ------------------ SCHEDULING of agents
 
     public function notify(Record $record)
     {
+        if (Queue::size() > $this->throttlingTreshold()) {
+            return;
+        }
+
         $trigger_label = $record->label;
 
         if (! isset($this->triggers[$trigger_label])) {

resources/views/status.blade.php

 @extends('layouts.app')
 
+@php
+$scheduler = \App\AgentScheduler::get();
+@endphp
+
 @section('title', 'Status')
 
 @section('content')
@@ -7,11 +11,29 @@
     <h1>Status</h1>
 
     <h2>Jobs</h2>
-    <p>Jobs in queue: {{ Queue::size() }}</p>
+    <p>Analysis jobs in queue: {{ Queue::size() }}</p>
+    <p>
+        Throttling threshold: {{ $scheduler->throttlingTreshold() }}
+    </p>
+    <p class="text-muted">
+        <i class="fas fa-question-circle"></i> When queue size reaches threshold, any new analysis job will be discarded
+        until the queue size falls below threshold.
+    </p>
 
     <h2>Database</h2>
     <p>Servers : {{ \App\Server::count() }}</p>
     <p>Records : {{ \App\Record::count() }}</p>
     <p>Reports : {{ \App\Report::count() }}</p>
+
+    <h2>Agents</h2>
+    <p>Autodiscovered <b>{{ $scheduler->sensors()->count() }}</b> analysis agents</p>
+
+    <table class="table table-sm">
+        @foreach ($scheduler->sensors() as $sensor)
+        <tr>
+            <td>{{ get_class($sensor) }}</td>
+        </tr>
+        @endforeach
+    </table>
 </div>
 @endsection
\ No newline at end of file