Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
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 })
Functions ¶
This section is empty.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.