failover

Author: segy

README.md

@@ -32,3 +32,14 @@ Cache::config('redis', [
     'server' => ['10.10.10.10:6379', '10.10.10.20:6379', '10.10.10.30:6379']
 ]);
 ```
+
+## Slave failover / distribution
+
+Slave failover / distibution can be configured by `failover` configuration key. See [related chapter](https://github.com/phpredis/phpredis/blob/master/cluster.markdown#automatic-slave-failover--distribution) in phpredis cluster readme.
+
+Possible values are:
+
+- *none* (default)
+- *error*
+- *distribute*
+- *slaves*

src/Cache/Engine/RedisClusterEngine.php

@@ -41,7 +41,8 @@ class RedisClusterEngine extends RedisEngine
         'probability' => 100,
         'server' => [],
         'timeout' => 2,
-        'read_timeout' => 2
+        'read_timeout' => 2,
+        'failover' => 'none'
     ];
 
     /**
@@ -65,6 +66,23 @@ protected function _connect()
     {
         try {
             $this->_Redis = new \RedisCluster($this->_config['name'], $this->_config['server'], $this->_config['timeout'], $this->_config['read_timeout'], $this->_config['persistent']);
+
+            switch ($this->_config['failover']) {
+                case 'error':
+                    $this->_Redis->setOption(\RedisCluster::OPT_SLAVE_FAILOVER, \RedisCluster::FAILOVER_ERROR);
+                    break;
+
+                case 'distribute':
+                    $this->_Redis->setOption(\RedisCluster::OPT_SLAVE_FAILOVER, \RedisCluster::FAILOVER_DISTRIBUTE);
+                    break;
+
+                case 'slaves':
+                    $this->_Redis->setOption(\RedisCluster::OPT_SLAVE_FAILOVER, \RedisCluster::FAILOVER_DISTRIBUTE_SLAVES);
+                    break;
+
+                default:
+                    $this->_Redis->setOption(\RedisCluster::OPT_SLAVE_FAILOVER, \RedisCluster::FAILOVER_NONE);
+            }
         } catch (\RedisClusterException $e) {
             return false;
         }