-
Notifications
You must be signed in to change notification settings - Fork 0
/
wredis.go
67 lines (56 loc) · 1.17 KB
/
wredis.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
package wredis
import "github.com/redis/go-redis/v9"
type (
UniversalClient redis.UniversalClient
Client struct {
UniversalClient
}
)
type iClient interface {
AddHook(hook redis.Hook)
UniversalClient
}
type Configuration func(client iClient)
func WithHooks(hooks ...redis.Hook) Configuration {
return func(client iClient) {
for _, hook := range hooks {
client.AddHook(hook)
}
}
}
func New(options Options, configurations ...Configuration) *Client {
var (
opts = redis.Options(options)
client = redis.NewClient(&opts)
)
for _, c := range configurations {
c(client)
}
return &Client{
UniversalClient: client,
}
}
func NewCluster(options ClusterOptions, configurations ...Configuration) *Client {
var (
opts = redis.ClusterOptions(options)
client = redis.NewClusterClient(&opts)
)
for _, c := range configurations {
c(client)
}
return &Client{
UniversalClient: client,
}
}
func NewRing(options RingOptions, configurations ...Configuration) *Client {
var (
opts = redis.RingOptions(options)
client = redis.NewRing(&opts)
)
for _, c := range configurations {
c(client)
}
return &Client{
UniversalClient: client,
}
}