feat: support quit cluster gracefully. Close #315

API.md

@@ -153,14 +153,14 @@ the current connection.
 var redis = new Redis();
 redis.monitor(function (err, monitor) {
   // Entering monitoring mode.
-  monitor.on('monitor', function (time, args) {
+  monitor.on('monitor', function (time, args, source, database) {
     console.log(time + ": " + util.inspect(args));
   });
 });
 
 // supports promise as well as other commands
 redis.monitor().then(function (monitor) {
-  monitor.on('monitor', function (time, args) {
+  monitor.on('monitor', function (time, args, source, database) {
     console.log(time + ": " + util.inspect(args));
   });
 });
@@ -218,6 +218,7 @@ Create a Redis instance
     * [new Cluster(startupNodes, options)](#new_Cluster_new)
     * [.connect()](#Cluster+connect) ⇒ <code>Promise</code>
     * [.disconnect()](#Cluster+disconnect)
+    * [.quit()](#Cluster+quit) ⇒ <code>Promise</code>
     * [.nodes([role])](#Cluster+nodes) ⇒ <code>[Array.&lt;Redis&gt;](#Redis)</code>
     * [.getBuiltinCommands()](#Commander+getBuiltinCommands) ⇒ <code>Array.&lt;string&gt;</code>
     * [.createBuiltinCommand(commandName)](#Commander+createBuiltinCommand) ⇒ <code>object</code>
@@ -256,6 +257,13 @@ Connect to a cluster
 ### cluster.disconnect()
 Disconnect from every node in the cluster.
 
+**Kind**: instance method of <code>[Cluster](#Cluster)</code>  
+**Access:** public  
+<a name="Cluster+quit"></a>
+
+### cluster.quit() ⇒ <code>Promise</code>
+Quit the cluster gracefully.
+
 **Kind**: instance method of <code>[Cluster](#Cluster)</code>  
 **Access:** public  
 <a name="Cluster+nodes"></a>

lib/cluster/index.js

@@ -208,6 +208,28 @@ Cluster.prototype.disconnect = function (reconnect) {
   this.connectionPool.reset([]);
 };
 
+/**
+ * Quit the cluster gracefully.
+ *
+ * @return {Promise}
+ * @public
+ */
+Cluster.prototype.quit = function (callback) {
+  this.setStatus('disconnecting');
+
+  this.manuallyClosing = true;
+
+  if (this.reconnectTimeout) {
+    clearTimeout(this.reconnectTimeout);
+    this.reconnectTimeout = null;
+  }
+  return Promise.all(this.nodes().map(function (node) {
+    return node.quit();
+  })).then(function (res) {
+    return res.length;
+  }).nodeify(callback);
+};
+
 /**
  * Get nodes with the specified role
  *