infrastructures.*RedisManager.NewRedisClient - Code Metrics - Inspection of ":page_facing_up: Update Licence" - memnix/memnix-rest - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — main ( 7e619e...36c76a )

by Yume

created 2024-02-20 12:07 UTC

infrastructures.*RedisManager.NewRedisClient A

↳ Parent: infrastructures/redis.go

Complexity

Conditions

Size

Total Lines	13
Code Lines	9

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	2
eloc	9
dl	0
loc	13
rs	9.95
c	0
b	0
f	0
nop	1

package infrastructures

import (
	"context"
	"log/slog"
	"sync"
	"time"

	"github.com/gofiber/fiber/v2/log"
	"github.com/memnix/memnix-rest/config"
	"github.com/redis/go-redis/extra/redisotel/v9"
	"github.com/redis/go-redis/v9"
)

type RedisManager struct {
	client *redis.Client
}

var (
	redisInstance *RedisManager //nolint:gochecknoglobals //Singleton
	redisOnce     sync.Once     //nolint:gochecknoglobals //Singleton
)

func GetRedisClient() *redis.Client {
	return GetRedisManagerInstance().GetRedisClient()
}

func GetRedisManagerInstance() *RedisManager {
	redisOnce.Do(func() {
		redisInstance = &RedisManager{}
	})
	return redisInstance
}

func (r *RedisManager) ConnectRedis(redisConf config.RedisConfig) error {
	r.client = r.NewRedisClient(redisConf)

	_, err := r.client.Ping(context.Background()).Result()
	if err != nil {
		return err
	}

	return nil
}

func (r *RedisManager) CloseRedis() error {
	return r.client.Close()
}

func (r *RedisManager) GetRedisClient() *redis.Client {
	return r.client
}

func (r *RedisManager) NewRedisClient(redisConf config.RedisConfig) *redis.Client {
	client := redis.NewClient(&redis.Options{
		Addr:         redisConf.Addr,
		MinIdleConns: redisConf.MinIdleConns,
		PoolSize:     redisConf.PoolSize,
		PoolTimeout:  time.Duration(redisConf.PoolTimeout) * time.Second,
	})

	if err := redisotel.InstrumentTracing(client); err != nil {
		log.Error("failed to instrument redis", slog.Any("error", err))
	}

	return client
}


1			package infrastructures
2
3			import (
4			"context"
5			"log/slog"
6			"sync"
7			"time"
8
9			"github.com/gofiber/fiber/v2/log"
10			"github.com/memnix/memnix-rest/config"
11			"github.com/redis/go-redis/extra/redisotel/v9"
12			"github.com/redis/go-redis/v9"
13			)
14
15			type RedisManager struct {
16			client *redis.Client
17			}
18
19			var (
20			redisInstance *RedisManager //nolint:gochecknoglobals //Singleton
21			redisOnce sync.Once //nolint:gochecknoglobals //Singleton
22			)
23
24			func GetRedisClient() *redis.Client {
25			return GetRedisManagerInstance().GetRedisClient()
26			}
27
28			func GetRedisManagerInstance() *RedisManager {
29			redisOnce.Do(func() {
30			redisInstance = &RedisManager{}
31			})
32			return redisInstance
33			}
34
35			func (r *RedisManager) ConnectRedis(redisConf config.RedisConfig) error {
36			r.client = r.NewRedisClient(redisConf)
37
38			_, err := r.client.Ping(context.Background()).Result()
39			if err != nil {
40			return err
41			}
42
43			return nil
44			}
45
46			func (r *RedisManager) CloseRedis() error {
47			return r.client.Close()
48			}
49
50			func (r RedisManager) GetRedisClient() redis.Client {
51			return r.client
52			}
53
54			func (r RedisManager) NewRedisClient(redisConf config.RedisConfig) redis.Client {
55			client := redis.NewClient(&redis.Options{
56			Addr: redisConf.Addr,
57			MinIdleConns: redisConf.MinIdleConns,
58			PoolSize: redisConf.PoolSize,
59			PoolTimeout: time.Duration(redisConf.PoolTimeout) * time.Second,
60			})
61
62			if err := redisotel.InstrumentTracing(client); err != nil {
63			log.Error("failed to instrument redis", slog.Any("error", err))
64			}
65
66			return client
67			}
68

memnix / memnix-rest

Push — main ( 7e619e...36c76a )

infrastructures.*RedisManager.NewRedisClient A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like