mirror of https://github.com/go-redis/redis.git
Merge cc4810cc5a
into 80c9f5bb77
This commit is contained in:
commit
ca352ceb1d
|
@ -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