Use redis universal client instead of a concrete type

harvester.go

@@ -61,8 +61,8 @@ type Builder struct {
 	monitorConsulCfg         *consulConfig
 	err                      error
 	chNotify                 chan<- config.ChangeNotification
-	monitorRedisClient       *redis.Client
-	seedRedisClient          *redis.Client
+	monitorRedisClient       redis.UniversalClient
+	seedRedisClient          redis.UniversalClient
 	monitorRedisPollInterval time.Duration
 }
 
@@ -114,7 +114,7 @@ func (b *Builder) WithConsulMonitor(addr, dataCenter, token string, timeout time
 }
 
 // WithRedisSeed enables support for seeding values with redis.
-func (b *Builder) WithRedisSeed(client *redis.Client) *Builder {
+func (b *Builder) WithRedisSeed(client redis.UniversalClient) *Builder {
 	if b.err != nil {
 		return b
 	}
@@ -128,7 +128,7 @@ func (b *Builder) WithRedisSeed(client *redis.Client) *Builder {
 
 // WithRedisMonitor enables support for monitoring keys in Redis. It automatically parses the config
 // and monitors every field found tagged with ConsulLogger.
-func (b *Builder) WithRedisMonitor(client *redis.Client, pollInterval time.Duration) *Builder {
+func (b *Builder) WithRedisMonitor(client redis.UniversalClient, pollInterval time.Duration) *Builder {
 	if b.err != nil {
 		return b
 	}

harvester_test.go

@@ -20,8 +20,8 @@ func TestCreateWithConsulAndRedis(t *testing.T) {
 	type args struct {
 		cfg                    interface{}
 		consulAddress          string
-		seedRedisClient        *redis.Client
-		monitorRedisClient     *redis.Client
+		seedRedisClient        redis.UniversalClient
+		monitorRedisClient     redis.UniversalClient
 		monitoringPollInterval time.Duration
 	}
 	tests := map[string]struct {

monitor/redis/watcher.go

@@ -14,13 +14,13 @@ import (
 
 // Watcher of Redis changes.
 type Watcher struct {
-	client       *redis.Client
+	client       redis.UniversalClient
 	keys         []string
 	pollInterval time.Duration
 }
 
 // New watcher.
-func New(client *redis.Client, pollInterval time.Duration, keys []string) (*Watcher, error) {
+func New(client redis.UniversalClient, pollInterval time.Duration, keys []string) (*Watcher, error) {
 	if client == nil {
 		return nil, errors.New("client is nil")
 	}

monitor/redis/watcher_integration_test.go

@@ -63,13 +63,13 @@ func TestWatch(t *testing.T) {
 	}
 }
 
-func set(t *testing.T, client *redis.Client, key string, val string) {
+func set(t *testing.T, client redis.UniversalClient, key string, val string) {
 	getResult, err := client.Set(context.Background(), key, val, 0).Result()
 	require.NoError(t, err)
 	require.Equal(t, "OK", getResult)
 }
 
-func del(t *testing.T, client *redis.Client, key string) {
+func del(t *testing.T, client redis.UniversalClient, key string) {
 	delResult, err := client.Del(context.Background(), key).Result()
 	require.NoError(t, err)
 	require.Equal(t, int64(1), delResult)

monitor/redis/watcher_test.go

@@ -13,7 +13,7 @@ import (
 
 func TestNew(t *testing.T) {
 	type args struct {
-		client       *redis.Client
+		client       redis.UniversalClient
 		pollInterval time.Duration
 		keys         []string
 	}

seed/redis/getter.go

@@ -10,11 +10,11 @@ import (
 
 // Getter definition.
 type Getter struct {
-	client *redis.Client
+	client redis.UniversalClient
 }
 
 // New creates a getter.
-func New(client *redis.Client) (*Getter, error) {
+func New(client redis.UniversalClient) (*Getter, error) {
 	if client == nil {
 		return nil, errors.New("client is nil")
 	}

seed/redis/getter_test.go

@@ -9,7 +9,7 @@ import (
 
 func TestNew(t *testing.T) {
 	type args struct {
-		client *redis.Client
+		client redis.UniversalClient
 	}
 	tests := map[string]struct {
 		args        args