🔥 Remove invalid initialization option (#1252)

Co-authored-by: Yusuke Kato <[email protected]>
vdaas · May 25, 2021 · a7452e4 · a7452e4
1 parent 5a66d20
commit a7452e4
Showing 1 changed file with 0 additions and 7 deletions.
diff --git 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,