24
1
Fork 0

Allow to set custom retry parameters

This commit is contained in:
minvs1 2020-04-21 23:30:39 +03:00
parent 471c9e8559
commit 7aead375d8
2 changed files with 12 additions and 2 deletions

View File

@ -69,6 +69,16 @@ const conf = convict({
default: false,
env: 'REDIS_EVENT_EXPIRE'
},
redis_retry_time: {
format: Number,
default: 10000,
env: 'REDIS_RETRY_TIME'
},
redis_retry_delay: {
format: Number,
default: 500,
env: 'REDIS_RETRY_DELAY'
},
listen_address: {
format: 'ipaddress',
default: '0.0.0.0',

View File

@ -11,12 +11,12 @@ module.exports = function(config) {
const client = redis.createClient({
host: config.redis_host,
retry_strategy: options => {
if (options.total_retry_time > 10000) {
if (options.total_retry_time > config.redis_retry_time) {
client.emit('error', 'Retry time exhausted');
return new Error('Retry time exhausted');
}
return 500;
return config.redis_retry_delay;
}
});