[12.x] flushAll for Redis cluster connections

Author: vadimonus

src/Illuminate/Redis/Connections/PhpRedisClusterConnection.php

@@ -63,6 +63,24 @@ public function flushdb()
         }
     }
 
+    /**
+     * Flush the selected Redis database on all master nodes.
+     *
+     * @return void
+     */
+    public function flushAll()
+    {
+        $arguments = func_get_args();
+
+        $async = strtoupper((string) ($arguments[0] ?? null)) === 'ASYNC';
+
+        foreach ($this->client->_masters() as $master) {
+            $async
+                ? $this->command('rawCommand', [$master, 'flushall', 'async'])
+                : $this->command('flushall', [$master]);
+        }
+    }
+
     /**
      * Return default node to use for cluster.
      *

src/Illuminate/Redis/Connections/PredisClusterConnection.php

@@ -2,6 +2,7 @@
 
 namespace Illuminate\Redis\Connections;
 
+use Predis\Command\Redis\FLUSHALL;
 use Predis\Command\Redis\FLUSHDB;
 use Predis\Command\ServerFlushDatabase;
 
@@ -22,4 +23,16 @@ public function flushdb()
             $node->executeCommand(tap(new $command)->setArguments(func_get_args()));
         }
     }
+
+    /**
+     * Flush the selected Redis database on all master nodes.
+     *
+     * @return void
+     */
+    public function flushAll()
+    {
+        foreach ($this->client as $node) {
+            $node->executeCommand(tap(new FLUSHALL())->setArguments(func_get_args()));
+        }
+    }
 }