代码拉取完成,页面将自动刷新
package gredis
import (
"time"
"github.com/gomodule/redigo/redis"
)
type Conf struct {
Addr string
MaxIdle int
MaxActive int
IdleTimeout time.Duration
Wait bool
DB string
PassWord string
}
type ReidsConn struct {
redis.Conn
}
func (c *Conf) SetPool() redis.Pool {
pool := redis.Pool{
MaxIdle: c.MaxIdle,
MaxActive: c.MaxActive,
IdleTimeout: c.IdleTimeout,
Wait: c.Wait,
Dial: func() (redis.Conn, error) {
conn, err := redis.Dial("tcp", c.Addr)
if err != nil {
return conn, err
}
if c.PassWord != "" {
_, err = conn.Do("auth", c.PassWord)
if err != nil {
return conn, err
}
}
if c.DB != "" {
_, err = conn.Do("select", c.DB)
if err != nil {
return conn, err
}
}
return conn, err
},
}
return pool
}
func SetConn(pool redis.Pool) ReidsConn {
defer pool.Close()
conn := ReidsConn{
pool.Get(),
}
return conn
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。