redis

var Module = fx.Provide(func(cfg *conf.Config, logger *log.Logger) *redis.Pool {
	redisPool = &redis.Pool{
		MaxIdle:     cfg.RedisConf.MaxIdle,
		MaxActive:   cfg.RedisConf.MaxActive,
		IdleTimeout: cfg.RedisConf.IdleTimeout * time.Second,
		Dial: func() (redis.Conn, error) {
			setPassword := redis.DialPassword(cfg.RedisConf.Auth)
			dial, err := redis.Dial(cfg.RedisConf.Protocol, cfg.RedisConf.Host+":"+cfg.RedisConf.Port, setPassword)
			if err != nil {
				logger.ZapLogger.Error(
					"[redis-conn-error]",
					zap.Any("module", "redis"),
					zap.Any("type", "cache"),
					zap.Any("info", cfg.RedisConf.Protocol+cfg.RedisConf.Host+":"+cfg.RedisConf.Port),
				)
			}
			dial.Do("SELECT", cfg.RedisConf.Db)
			return dial, err
		},
	}
	return redisPool
})