From a7452e480dcb2207f175f1ea6ed1d7a9ba7c58f0 Mon Sep 17 00:00:00 2001
From: Rintaro Okamura <rintaro.okamura@gmail.com>
Date: Tue, 25 May 2021 14:35:32 +0900
Subject: [PATCH] :fire: Remove invalid initialization option (#1252)

Co-authored-by: Yusuke Kato <kpango@vdaas.org>
---
 internal/db/kvs/redis/redis.go | 7 -------
 1 file changed, 7 deletions(-)

diff --git a/internal/db/kvs/redis/redis.go b/internal/db/kvs/redis/redis.go
index 85dc8c79d9..eabd97e850 100644
--- a/internal/db/kvs/redis/redis.go
+++ b/internal/db/kvs/redis/redis.go
@@ -230,13 +230,6 @@ func (rc *redisClient) newClusterClient(ctx context.Context) (c *redis.ClusterCl
 	} else {
 		c = redis.NewClusterClient(&redis.ClusterOptions{
 			Addrs: rc.addrs,
-			NewClient: func(opt *redis.Options) *redis.Client {
-				c, err := rc.newClient(ctx)
-				if err != nil {
-					return redis.NewClient(opt)
-				}
-				return c
-			},
 			Dialer:             rc.dialerFunc,
 			MaxRedirects:       rc.maxRedirects,
 			ReadOnly:           rc.readOnly,