1 files changed, 84 insertions, 0 deletions
diff --git a/plugins/redis/clients.go b/plugins/redis/clients.go
new file mode 100644
index 00000000..d0a184d2
--- /dev/null
+++ b/plugins/redis/clients.go
@@ -0,0 +1,84 @@
+package redis
+
+import (
+	"github.com/go-redis/redis/v8"
+	"github.com/spiral/errors"
+)
+
+// RedisClient return a client based on the provided section key
+// key sample: kv.some-section.redis
+// kv.redis
+// redis (root)
+func (p *Plugin) RedisClient(key string) (redis.UniversalClient, error) {
+	const op = errors.Op("redis_get_client")
+
+	if !p.cfgPlugin.Has(key) {
+		return nil, errors.E(op, errors.Errorf("no such section: %s", key))
+	}
+
+	cfg := &Config{}
+
+	err := p.cfgPlugin.UnmarshalKey(key, cfg)
+	if err != nil {
+		return nil, errors.E(op, err)
+	}
+
+	cfg.InitDefaults()
+
+	uc := redis.NewUniversalClient(&redis.UniversalOptions{
+		Addrs:              cfg.Addrs,
+		DB:                 cfg.DB,
+		Username:           cfg.Username,
+		Password:           cfg.Password,
+		SentinelPassword:   cfg.SentinelPassword,
+		MaxRetries:         cfg.MaxRetries,
+		MinRetryBackoff:    cfg.MaxRetryBackoff,
+		MaxRetryBackoff:    cfg.MaxRetryBackoff,
+		DialTimeout:        cfg.DialTimeout,
+		ReadTimeout:        cfg.ReadTimeout,
+		WriteTimeout:       cfg.WriteTimeout,
+		PoolSize:           cfg.PoolSize,
+		MinIdleConns:       cfg.MinIdleConns,
+		MaxConnAge:         cfg.MaxConnAge,
+		PoolTimeout:        cfg.PoolTimeout,
+		IdleTimeout:        cfg.IdleTimeout,
+		IdleCheckFrequency: cfg.IdleCheckFreq,
+		ReadOnly:           cfg.ReadOnly,
+		RouteByLatency:     cfg.RouteByLatency,
+		RouteRandomly:      cfg.RouteRandomly,
+		MasterName:         cfg.MasterName,
+	})
+
+	return uc, nil
+}
+
+func (p *Plugin) DefaultClient() redis.UniversalClient {
+	cfg := &Config{}
+	cfg.InitDefaults()
+
+	uc := redis.NewUniversalClient(&redis.UniversalOptions{
+		Addrs:              cfg.Addrs,
+		DB:                 cfg.DB,
+		Username:           cfg.Username,
+		Password:           cfg.Password,
+		SentinelPassword:   cfg.SentinelPassword,
+		MaxRetries:         cfg.MaxRetries,
+		MinRetryBackoff:    cfg.MaxRetryBackoff,
+		MaxRetryBackoff:    cfg.MaxRetryBackoff,
+		DialTimeout:        cfg.DialTimeout,
+		ReadTimeout:        cfg.ReadTimeout,
+		WriteTimeout:       cfg.WriteTimeout,
+		PoolSize:           cfg.PoolSize,
+		MinIdleConns:       cfg.MinIdleConns,
+		MaxConnAge:         cfg.MaxConnAge,
+		PoolTimeout:        cfg.PoolTimeout,
+		IdleTimeout:        cfg.IdleTimeout,
+		IdleCheckFrequency: cfg.IdleCheckFreq,
+		ReadOnly:           cfg.ReadOnly,
+		RouteByLatency:     cfg.RouteByLatency,
+		RouteRandomly:      cfg.RouteRandomly,
+		MasterName:         cfg.MasterName,
+	})
+
+	return uc
+}