redis

type RedisClient interface {
	Get(ctx context.Context, key string) *redis.StringCmd
	Set(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.StatusCmd
	Del(ctx context.Context, keys ...string) *redis.IntCmd

	JSONGet(ctx context.Context, key string, paths ...string) *redis.JSONCmd
	JSONSet(ctx context.Context, key, path string, value interface{}) *redis.StatusCmd
	JSONDel(ctx context.Context, key string, path string) *redis.IntCmd

	HSet(ctx context.Context, key string, values ...interface{}) *redis.IntCmd
	HGet(ctx context.Context, key, field string) *redis.StringCmd

	Publish(ctx context.Context, channel string, message interface{}) *redis.IntCmd
	Subscribe(ctx context.Context, channels ...string) *redis.PubSub
	Ping(ctx context.Context) *redis.StatusCmd
}

type RedisConfiguration struct {
	// Address represents host:port list separated by ,
	Address            []string `envconfig:"REDIS_ADDRESS" required:"true"`
	InsecureSkipVerify bool     `envconfig:"REDIS_INSECURE_SKIP_VERIFY" default:"false"`
	CACert             string   `envconfig:"REDIS_CA_CERT"`
	Cert               string   `envconfig:"REDIS_CERT"`
	CertKey            string   `envconfig:"REDIS_CERT_KEY"`
}