extend redis cluster params

swoft-cloud · Oct 13, 2019 · 7a678fd · 7a678fd
1 parent 9d2a653
commit 7a678fd
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 2 deletions.
diff --git a/src/redis/src/Connector/PhpRedisConnector.php b/src/redis/src/Connector/PhpRedisConnector.php
@@ -62,6 +62,8 @@ public function connect(array $config, array $option): Redis
      *
      * @return RedisCluster
      * @throws RedisClusterException
+     *
+     * @see https://raw.githubusercontent.com/zgb7mtr/phpredis_cluster_phpdoc/master/src/RedisCluster.php
      */
     public function connectToCluster(array $config, array $option): RedisCluster
     {
@@ -71,8 +73,9 @@ public function connectToCluster(array $config, array $option): RedisCluster
         $timeout     = $option['timeout'] ?? 0;
         $persistent  = $option['persistent'] ?? false;
         $name        = $option['name'] ?? '';
+        $auth        = $option['auth'] ?? '';
 
-        $redisCluster = new RedisCluster($name, $servers, $timeout, $readTimeout, $persistent);
+        $redisCluster = new RedisCluster($name, $servers, $timeout, $readTimeout, $persistent, $auth);
         return $redisCluster;
     }
 

diff --git a/src/redis/test/testing/bean.php b/src/redis/test/testing/bean.php
@@ -32,6 +32,7 @@
         'option'   => [
             'timeout'    => 3,
             'persistent' => true,
+            'auth'       => 'passwordAuth-xxxx',
         ],
         'clusters' => [
             [

diff --git a/src/redis/test/unit/Command/StringTest.php b/src/redis/test/unit/Command/StringTest.php
@@ -57,7 +57,7 @@ public function testInc()
     {
         $key = \uniqid();
 
-        $redis = Redis::connection('redis.inc.pool');
+        $redis         = Redis::connection('redis.inc.pool');
 
         $this->assertEquals(1, $redis->incrBy($key, 1));
         $redis->set($key, 2);