43 lines
865 B
Go
43 lines
865 B
Go
|
package redis
|
||
|
|
|
||
|
|
import (
|
||
|
|
"fmt"
|
||
|
|
|
||
|
|
"git.loafle.net/overflow/overflow_gateway_app/conf"
|
||
|
|
|
||
|
|
"git.loafle.net/commons_go/logging"
|
||
|
|
crp "git.loafle.net/commons_go/redis_pool"
|
||
|
|
"github.com/garyburd/redigo/redis"
|
||
|
|
)
|
||
|
|
|
||
|
|
var RedisPool crp.Pool
|
||
|
|
|
||
|
|
func ExternalInit() {
|
||
|
|
ph := &redisPoolHandlers{}
|
||
|
|
ph.MaxCapacity = conf.Config.Redis.Pool.MaxCapacity
|
||
|
|
ph.MaxIdle = conf.Config.Redis.Pool.MaxIdle
|
||
|
|
ph.IdleTimeout = conf.Config.Redis.Pool.IdleTimeout
|
||
|
|
ph.Wait = conf.Config.Redis.Pool.Wait
|
||
|
|
|
||
|
|
RedisPool = crp.New(ph)
|
||
|
|
|
||
|
|
if err := RedisPool.Start(); nil != err {
|
||
|
|
logging.Logger().Panic(fmt.Sprintf("App: %v", err))
|
||
|
|
return
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
func ExternalDestroy() {
|
||
|
|
if nil != RedisPool {
|
||
|
|
RedisPool.Stop()
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
type redisPoolHandlers struct {
|
||
|
|
crp.PoolHandlers
|
||
|
|
}
|
||
|
|
|
||
|
|
func (ph *redisPoolHandlers) Dial() (redis.Conn, error) {
|
||
|
|
return redis.Dial(conf.Config.Redis.Network, conf.Config.Redis.Addr)
|
||
|
|
}
|