Add configuration for Redis clusters

laravel · Apr 19, 2024 · e4bed34 · e4bed34
1 parent 4a08256
commit e4bed34
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/config/reverb.php b/config/reverb.php
@@ -39,6 +39,7 @@
             'scaling' => [
                 'enabled' => env('REVERB_SCALING_ENABLED', false),
                 'channel' => env('REVERB_SCALING_CHANNEL', 'reverb'),
+                'cluster_enabled' => env('REVERB_SCALING_CLUSTER_ENABLED', false),
             ],
             'pulse_ingest_interval' => env('REVERB_PULSE_INGEST_INTERVAL', 15),
             'telescope_ingest_interval' => env('REVERB_TELESCOPE_INGEST_INTERVAL', 15),

diff --git a/src/Servers/Reverb/Publishing/RedisPubSubProvider.php b/src/Servers/Reverb/Publishing/RedisPubSubProvider.php
@@ -19,7 +19,8 @@ class RedisPubSubProvider implements PubSubProvider
     public function __construct(
         protected RedisClientFactory $clientFactory,
         protected PubSubIncomingMessageHandler $messageHandler,
-        protected string $channel
+        protected string $channel,
+        protected bool $clusterMode = false
     ) {
         //
     }
@@ -85,7 +86,7 @@ public function publish(array $payload): PromiseInterface
      */
     protected function redisUrl(): string
     {
-        $config = Config::get('database.redis.default');
+        $config = Config::get($this->clusterMode ? 'database.redis.clusters.default.0' : 'database.redis.default');
 
         [$host, $port, $protocol, $query] = [
             $config['host'],

diff --git a/src/Servers/Reverb/ReverbServerProvider.php b/src/Servers/Reverb/ReverbServerProvider.php
@@ -37,7 +37,8 @@ public function register(): void
         $this->app->singleton(PubSubProvider::class, fn ($app) => new RedisPubSubProvider(
             $app->make(RedisClientFactory::class),
             $app->make(PubSubIncomingMessageHandler::class),
-            $this->config['scaling']['channel'] ?? 'reverb'
+            $this->config['scaling']['channel'] ?? 'reverb',
+            $this->config['scaling']['cluster_enabled'] ?? false
         ));
     }