diff --git a/lib/cluster/index.js b/lib/cluster/index.js index bbe5e81f..19702e3c 100644 --- a/lib/cluster/index.js +++ b/lib/cluster/index.js @@ -35,6 +35,8 @@ var DelayQueue = require('./delay_queue'); * if `retryDelayOnClusterDown` is valid delay time. * @param {number} [options.retryDelayOnTryAgain=100] - When a TRYAGAIN error is received, client will retry * if `retryDelayOnTryAgain` is valid delay time. + * @param {number} [options.slotsRefreshTimeout=1000] - The milliseconds before a timeout occurs while refreshing + * slots from the cluster. * @param {Object} [options.redisOptions] - Passed to the constructor of `Redis`. * @extends [EventEmitter](http://nodejs.org/api/events.html#events_class_events_eventemitter) * @extends Commander @@ -103,7 +105,8 @@ Cluster.defaultOptions = { maxRedirections: 16, retryDelayOnFailover: 100, retryDelayOnClusterDown: 100, - retryDelayOnTryAgain: 100 + retryDelayOnTryAgain: 100, + slotsRefreshTimeout: 1000 }; util.inherits(Cluster, EventEmitter); @@ -609,7 +612,7 @@ Cluster.prototype.getInfoFromNode = function (redis, callback) { _this.connectionPool.reset(nodes); callback(); - }, 1000)); + }, this.options.slotsRefreshTimeout)); }; /**