Add configuration for Redis cluster support (#166)

* Add configuration for Redis clusters * Update configuration to specify Redis connection data * Remove unused config lines
laravel · Apr 22, 2024 · 78d8db3 · 78d8db3
1 parent 4a08256
commit 78d8db3
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 3 deletions.
diff --git a/config/reverb.php b/config/reverb.php
@@ -39,6 +39,12 @@
             'scaling' => [
                 'enabled' => env('REVERB_SCALING_ENABLED', false),
                 'channel' => env('REVERB_SCALING_CHANNEL', 'reverb'),
+                'server' => [
+                    'host' => env('REDIS_HOST', '127.0.0.1'),
+                    'port' => env('REDIS_PORT', '6379'),
+                    'password' => env('REDIS_PASSWORD'),
+                    'database' => env('REDIS_DB', '0'),
+                ],
             ],
             '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 array $server = []
     ) {
         //
     }
@@ -85,7 +86,7 @@ public function publish(array $payload): PromiseInterface
      */
     protected function redisUrl(): string
     {
-        $config = Config::get('database.redis.default');
+        $config = empty($this->server) ? Config::get('database.redis.default') : $this->server;
 
         [$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']['server'] ?? []
         ));
     }