@@ -38,7 +38,7 @@ const (
3838)
3939
4040var (
41- redisPort = "6380 "
41+ redisPort = "6379 "
4242 redisAddr = ":" + redisPort
4343)
4444
@@ -59,14 +59,17 @@ var (
5959)
6060
6161var cluster = & clusterScenario {
62- ports : []string {"16379 " , "16380 " , "16381 " , "16382 " , "16383 " , "16384 " },
62+ ports : []string {"16600 " , "16601 " , "16602 " , "16603 " , "16604 " , "16605 " },
6363 nodeIDs : make ([]string , 6 ),
6464 processes : make (map [string ]* redisProcess , 6 ),
6565 clients : make (map [string ]* redis.Client , 6 ),
6666}
6767
68+ // Redis Software Cluster
6869var RECluster = false
69- var USE_CONTAINERIZED_REDIS = false
70+
71+ // Redis Community Edition Docker
72+ var RCEDocker = false
7073
7174func registerProcess (port string , p * redisProcess ) {
7275 if processes == nil {
@@ -83,8 +86,10 @@ var _ = BeforeSuite(func() {
8386 }
8487 var err error
8588 RECluster , _ = strconv .ParseBool (os .Getenv ("RE_CLUSTER" ))
86- USE_CONTAINERIZED_REDIS , _ = strconv .ParseBool (os .Getenv ("USE_CONTAINERIZED_REDIS" ))
87- if ! RECluster || ! USE_CONTAINERIZED_REDIS {
89+ RCEDocker , _ = strconv .ParseBool (os .Getenv ("RCE_DOCKER" ))
90+ fmt .Printf ("RECluster: %v\n " , RECluster )
91+ fmt .Printf ("RCEDocker: %v\n " , RCEDocker )
92+ if ! RECluster || ! RCEDocker {
8893
8994 redisMain , err = startRedis (redisPort )
9095 Expect (err ).NotTo (HaveOccurred ())
@@ -122,6 +127,9 @@ var _ = BeforeSuite(func() {
122127 } else {
123128 redisPort = rediStackPort
124129 redisAddr = rediStackAddr
130+ // populate cluster node information
131+ Expect (configureClusterTopology (ctx , cluster )).NotTo (HaveOccurred ())
132+
125133 }
126134})
127135
@@ -155,8 +163,8 @@ func redisOptions() *redis.Options {
155163 ContextTimeoutEnabled : true ,
156164
157165 MaxRetries : - 1 ,
158- PoolSize : 10 ,
159166
167+ PoolSize : 10 ,
160168 PoolTimeout : 30 * time .Second ,
161169 ConnMaxIdleTime : time .Minute ,
162170 }
0 commit comments