1

datasource/rdshelper.go

@@ -68,8 +68,8 @@ func InstanceCache() *RedisConn {
 func NewCache() *RedisConn {
 	pool := redis.Pool{
 		Dial: func() (redis.Conn, error) {
-			// redis.DialDatabase(1)
-			c, err := redis.Dial("tcp", fmt.Sprintf("%s:%d", conf.RdsCache.Host, conf.RdsCache.Port))
+			// redis.DialDatabase(5)
+			c, err := redis.Dial("tcp", fmt.Sprintf("%s:%d", conf.RdsCache.Host, conf.RdsCache.Port), redis.DialDatabase(5))
 			if err != nil {
 				log.Fatal("rdshelper.NewCache Dial error ", err)
 				return nil, err