Skip to content

Commit dd26df2

Browse files
Julien Riourueian
authored andcommitted
feat(url): Add valkey and valkeys schemes (#21)
Inspired by the valkey-py client. https://github.com/valkey-io/valkey-py/blob/v6.0.2/valkey/_parsers/url_parser.py#L40 Signed-off-by: Julien Riou <[email protected]> Signed-off-by: Rueian <[email protected]>
1 parent e67b908 commit dd26df2

File tree

2 files changed

+8
-2
lines changed

2 files changed

+8
-2
lines changed

url.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -41,11 +41,11 @@ func ParseURL(str string) (opt ClientOption, err error) {
4141
return dialer.Dial("unix", s)
4242
}
4343
opt.InitAddress = []string{strings.TrimSpace(u.Path)}
44-
case "rediss":
44+
case "rediss", "valkeys":
4545
opt.TLSConfig = &tls.Config{
4646
MinVersion: tls.VersionTLS12,
4747
}
48-
case "redis":
48+
case "redis", "valkey":
4949
default:
5050
return opt, fmt.Errorf("redis: invalid URL scheme: %s", u.Scheme)
5151
}

url_test.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,9 +15,15 @@ func TestParseURL(t *testing.T) {
1515
if opt, err := ParseURL("rediss://"); err != nil || opt.TLSConfig == nil {
1616
t.Fatalf("unexpected %v %v", opt, err)
1717
}
18+
if opt, err := ParseURL("valkeys://"); err != nil || opt.TLSConfig == nil {
19+
t.Fatalf("unexpected %v %v", opt, err)
20+
}
1821
if opt, err := ParseURL("unix://"); err != nil || opt.DialFn == nil {
1922
t.Fatalf("unexpected %v %v", opt, err)
2023
}
24+
if opt, err := ParseURL("valkey://"); err != nil {
25+
t.Fatalf("unexpected %v %v", opt, err)
26+
}
2127
if opt, err := ParseURL("redis://"); err != nil || opt.InitAddress[0] != "localhost:6379" {
2228
t.Fatalf("unexpected %v %v", opt, err)
2329
}

0 commit comments

Comments
 (0)