From 94c12e37716a9ac36f6f653430202be8c8d3b5ba Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Bar=C4=B1=C5=9F=20Soner=20U=C5=9Fakl=C4=B1?= Date: Fri, 14 May 2021 10:56:03 -0400 Subject: [PATCH] feat: #9508, add cluster support --- src/database/redis/connection.js | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/database/redis/connection.js b/src/database/redis/connection.js index 1c8179a346..6b43c9ee79 100644 --- a/src/database/redis/connection.js +++ b/src/database/redis/connection.js @@ -12,7 +12,9 @@ connection.connect = async function (options) { const redis_socket_or_host = options.host; let cxn; - if (redis_socket_or_host && String(redis_socket_or_host).indexOf('/') >= 0) { + if (options.cluster) { + cxn = new Redis.Cluster(options.cluster, options.options); + } else if (redis_socket_or_host && String(redis_socket_or_host).indexOf('/') >= 0) { // If redis.host contains a path name character, use the unix dom sock connection. ie, /tmp/redis.sock cxn = new Redis({ ...options.options,