Skip to content

Commit ec2a753

Browse files
author
Artem Mezentsev
committed
fix: redis adapter confguration
1 parent 21d2cc0 commit ec2a753

File tree

1 file changed

+6
-5
lines changed

1 file changed

+6
-5
lines changed

dbee/adapters/redis.go

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@ package adapters
22

33
import (
44
"encoding/gob"
5+
"fmt"
56

67
"github.com/redis/go-redis/v9"
78

@@ -23,11 +24,11 @@ var _ core.Adapter = (*Redis)(nil)
2324
type Redis struct{}
2425

2526
func (r *Redis) Connect(url string) (core.Driver, error) {
26-
c := redis.NewClient(&redis.Options{
27-
Addr: url,
28-
Password: "",
29-
DB: 0,
30-
})
27+
opt, err := redis.ParseURL(url)
28+
if err != nil {
29+
return nil, fmt.Errorf("unable to connect to redis database: %v", err)
30+
}
31+
c := redis.NewClient(opt)
3132

3233
return &redisDriver{
3334
redis: c,

0 commit comments

Comments
 (0)