Variable timings

Author: ghostzero

config/tmi-cluster.php

@@ -93,6 +93,29 @@
         'channels' => []
     ],
 
+    /*
+    |--------------------------------------------------------------------------
+    | TMI Supervisor & Process Configuration
+    |--------------------------------------------------------------------------
+    |
+    | Here you may specify the timings, we recommend to leave them on default
+    | and not to change them. You can delete this section if you always want
+    | to have the package defaults.
+    |
+    | All timings are specified in seconds.
+    |
+    */
+
+    'supervisor' => [
+        'stale' => 300,
+    ],
+
+    'process' => [
+        'stale' => 90,
+        'timeout' => 60,
+        'periodic_timer' => 2,
+    ],
+
     /*
     |--------------------------------------------------------------------------
     | TMI Cluster Auto Scaling Thresholds

src/Models/Supervisor.php

@@ -36,7 +36,7 @@ class Supervisor extends Model
 
     public function getIsStaleAttribute(): bool
     {
-        return $this->last_ping_at->diffInSeconds() >= 300;
+        return $this->last_ping_at->diffInSeconds() >= config('tmi-cluster.supervisor.stale', 300);
     }
 
     public function processes(): HasMany

src/Models/SupervisorProcess.php

@@ -46,7 +46,7 @@ public function supervisor(): BelongsTo
     public function getIsStaleAttribute(): bool
     {
         // we require at least 60 seconds for our restart cooldown
-        return $this->last_ping_at->diffInSeconds() >= 90;
+        return $this->last_ping_at->diffInSeconds() >= config('tmi-cluster.process.stale', 90);
     }
 
     public function getMemoryUsageAttribute(): string

src/Process/ProcessOptions.php

@@ -30,6 +30,6 @@ public function getSupervisor(): string
 
     public function getTimeout(): int
     {
-        return $this->options['timeout'] ?? 60;
+        return $this->options['timeout'] ?? config('tmi-cluster.process.timeout', 60);
     }
 }

src/TmiClusterClient.php

@@ -88,7 +88,8 @@ public static function make(ClusterClientOptions $options, Closure $output): sel
 
     private function registerPeriodicTimer(): void
     {
-        $this->client->getLoop()->addPeriodicTimer(2, function () {
+        $interval = config('tmi-cluster.process.periodic_timer', 2);
+        $this->client->getLoop()->addPeriodicTimer($interval, function () {
             $this->processPendingSignals();
 
             $this->processPendingCommands();