Add seperate config for stopping write redis connections

This commit is contained in:
Ajay
2022-11-07 23:04:18 -05:00
parent 98f202f6a9
commit e1a5ca64f0
3 changed files with 4 additions and 2 deletions

View File

@@ -137,7 +137,8 @@ addDefaults(config, {
disableOfflineQueue: true,
expiryTime: 24 * 60 * 60,
getTimeout: 40,
maxConnections: 15000
maxConnections: 15000,
maxWriteConnections: 1000
},
redisRead: {
enabled: false,

View File

@@ -6,6 +6,7 @@ interface RedisConfig extends redis.RedisClientOptions {
expiryTime: number;
getTimeout: number;
maxConnections: number;
maxWriteConnections: number;
}
interface RedisReadOnlyConfig extends redis.RedisClientOptions {

View File

@@ -68,7 +68,7 @@ if (config.redis?.enabled) {
});
});
exportClient.set = (key, value) => new Promise((resolve, reject) => {
if (activeRequests > config.redis.maxConnections) {
if (activeRequests > config.redis.maxWriteConnections) {
reject("Too many active requests");
return;
}