package redis_manager

import (
	"sync"
)

var (
	redisOfCluster = make(map[string]Redis)
	redisConfCluster = make(map[string]RedisConfig)

	locker sync.RWMutex
)

func InitRedisOfCluster(rs map[string]RedisConfig) {
	locker.Lock()
	defer locker.Unlock()

	redisConfCluster = rs

}

func get(name string) (Redis, bool) {
	locker.RLock()
	defer locker.RUnlock()

	r, h := redisOfCluster[name]

	return r, h
}
func Get(name string) (Redis, bool) {
	r,has:=get(name)

	if has{
		return r,r!=nil
	}

	locker.Lock()
	defer locker.Unlock()
	r, has = redisOfCluster[name]
	if has{
		return r,has
	}
	c,h:= redisConfCluster[name]
	if h{
		r = Create(c)
		redisOfCluster[name] = r
		return r, h
	}

	redisOfCluster[name] = nil

	return nil,false
}