mirror of https://github.com/go-redis/redis.git
Compare commits
2 Commits
7e6a725360
...
ca352ceb1d
Author | SHA1 | Date |
---|---|---|
Flc゛ | ca352ceb1d | |
Flc | cc4810cc5a |
|
@ -30,8 +30,6 @@ func InstrumentTracing(rdb redis.UniversalClient, opts ...TracingOption) error {
|
||||||
rdb.AddHook(newTracingHook(connString, opts...))
|
rdb.AddHook(newTracingHook(connString, opts...))
|
||||||
return nil
|
return nil
|
||||||
case *redis.ClusterClient:
|
case *redis.ClusterClient:
|
||||||
rdb.AddHook(newTracingHook("", opts...))
|
|
||||||
|
|
||||||
rdb.OnNewNode(func(rdb *redis.Client) {
|
rdb.OnNewNode(func(rdb *redis.Client) {
|
||||||
opt := rdb.Options()
|
opt := rdb.Options()
|
||||||
opts = addServerAttributes(opts, opt.Addr)
|
opts = addServerAttributes(opts, opt.Addr)
|
||||||
|
@ -40,8 +38,6 @@ func InstrumentTracing(rdb redis.UniversalClient, opts ...TracingOption) error {
|
||||||
})
|
})
|
||||||
return nil
|
return nil
|
||||||
case *redis.Ring:
|
case *redis.Ring:
|
||||||
rdb.AddHook(newTracingHook("", opts...))
|
|
||||||
|
|
||||||
rdb.OnNewNode(func(rdb *redis.Client) {
|
rdb.OnNewNode(func(rdb *redis.Client) {
|
||||||
opt := rdb.Options()
|
opt := rdb.Options()
|
||||||
opts = addServerAttributes(opts, opt.Addr)
|
opts = addServerAttributes(opts, opt.Addr)
|
||||||
|
|
Loading…
Reference in New Issue