Skip to content

Commit 493d095

Browse files
damianhodgkissluin
authored andcommitted
feat(cluster): add option to control timeout on cluster slots refresh (#475)
* add option to control refresh slots timeout * rename as per issue * missed one
1 parent e7b6352 commit 493d095

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

lib/cluster/index.js

+5-2
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,8 @@ var DelayQueue = require('./delay_queue');
3535
* if `retryDelayOnClusterDown` is valid delay time.
3636
* @param {number} [options.retryDelayOnTryAgain=100] - When a TRYAGAIN error is received, client will retry
3737
* if `retryDelayOnTryAgain` is valid delay time.
38+
* @param {number} [options.slotsRefreshTimeout=1000] - The milliseconds before a timeout occurs while refreshing
39+
* slots from the cluster.
3840
* @param {Object} [options.redisOptions] - Passed to the constructor of `Redis`.
3941
* @extends [EventEmitter](http://nodejs.org/api/events.html#events_class_events_eventemitter)
4042
* @extends Commander
@@ -103,7 +105,8 @@ Cluster.defaultOptions = {
103105
maxRedirections: 16,
104106
retryDelayOnFailover: 100,
105107
retryDelayOnClusterDown: 100,
106-
retryDelayOnTryAgain: 100
108+
retryDelayOnTryAgain: 100,
109+
slotsRefreshTimeout: 1000
107110
};
108111

109112
util.inherits(Cluster, EventEmitter);
@@ -609,7 +612,7 @@ Cluster.prototype.getInfoFromNode = function (redis, callback) {
609612

610613
_this.connectionPool.reset(nodes);
611614
callback();
612-
}, 1000));
615+
}, this.options.slotsRefreshTimeout));
613616
};
614617

615618
/**

0 commit comments

Comments
 (0)