redis_conn.go

package redis_manager

import (
	"sync"
)

var (
	def           Redis
	defaultConfig RedisConfig
	defLocker     sync.Locker
)

//SetDefault 设置默认redis
func SetDefault(r Redis) {
	def = r
}

//GetConnection 获取redis连接
func GetConnection() Redis {
	if def != nil {
		return def
	}

	defLocker.Lock()
	defer defLocker.Unlock()

	if def != nil {
		return def
	}

	def = Create(defaultConfig)
	return def
}