Implement RCM code

Signed-off-by: Niranjani Vivek <niranjaniv@google.com>

Author: niranjanivivek

translib/db/db.go

@@ -168,6 +168,11 @@ type Options struct {
 	KeySeparator       string //Overriden by the DB config file's separator.
 	IsWriteDisabled    bool   //Is write/set mode disabled ?
 	IsCacheEnabled     bool   //Is cache (Per Connection) allowed?
+	// Redis connection pools do not support transactional Redis operations.
+	// If the DB object will be used to perform transactions, the Transacation
+	// flag must be set to request a unique Redis client. Transactions include
+	// SCAN and MULTI.
+	TransactionsRequired bool
 
 	// OnChange caching for the DBs passed from Translib's Subscribe Infra
 	// to the Apps. SDB is the SubscribeDB() returned handle on which

translib/db/db_redis_opts.go

@@ -144,7 +144,7 @@ func adjustRedisOpts(dbOpt *Options) *redis.Options {
 	return &redisOpts
 }
 
-func init() {
+func initializeRedisOpts() {
 	flag.StringVar(&goRedisOpts, "go_redis_opts", "", "Options for go-redis")
 }
 

translib/db/db_stats.go

@@ -23,8 +23,6 @@ import (
 	"reflect"
 	"sync"
 	"time"
-
-	"github.com/go-redis/redis/v7"
 )
 
 ////////////////////////////////////////////////////////////////////////////////
@@ -524,29 +522,9 @@ func (config *DBStatsConfig) readFromDB() error {
 
 func readRedis(key string) (map[string]string, error) {
 
-	ipAddr := DefaultRedisLocalTCPEP
-	dbId := int(ConfigDB)
-	dbPassword := ""
-	if dbInstName := getDBInstName(ConfigDB); dbInstName != "" {
-		if isDbInstPresent(dbInstName) {
-			ipAddr = getDbTcpAddr(dbInstName)
-			dbId = getDbId(dbInstName)
-			dbPassword = getDbPassword(dbInstName)
-		}
-	}
-
-	client := redis.NewClient(&redis.Options{
-		Network:     "tcp",
-		Addr:        ipAddr,
-		Password:    dbPassword,
-		DB:          dbId,
-		DialTimeout: 0,
-		PoolSize:    1,
-	})
+	client := RedisClient(ConfigDB)
+	defer CloseRedisClient(client)
 
 	fields, e := client.HGetAll(key).Result()
-
-	client.Close()
-
 	return fields, e
 }