smart_streetlights/common/util/myredis.go

package util

import (
	"time"

	"github.com/go-redis/redis/v7"
)

const (
	REDIS_DBIDX_EDGE_DATA = 0
	REDIS_DBIDX_RAWDATA   = 1
)

func NewRedisClient(conf *RedisConfig, idx int) (*redis.Client, error) {
	r := redis.NewClient(&redis.Options{
		Addr:         conf.Redis_Address,
		Password:     conf.Redis_Password,
		DB:           idx,
		DialTimeout:  10 * time.Second,
		ReadTimeout:  30 * time.Second,
		WriteTimeout: 30 * time.Second,
		PoolSize:     10,
		PoolTimeout:  30 * time.Second,
	})
	return r, r.Ping().Err()
}