re
/
redis
forked from mirror/redis
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Tweak name

This commit is contained in:
Vladimir Mihailenco 2020-11-15 14:35:04 +02:00
parent 7bd3bffc5b
commit 16981c0c00
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
options.go
View File

@ -293,11 +293,12 @@ func newConnPool(opt *Options) *pool.ConnPool {
return pool.NewConnPool(&pool.Options{ return pool.NewConnPool(&pool.Options{
Dialer: func(ctx context.Context) (net.Conn, error) { Dialer: func(ctx context.Context) (net.Conn, error) {
var conn net.Conn var conn net.Conn
err := internal.WithSpan(ctx, "redis.dialer", func(ctx context.Context, span trace.Span) error { err := internal.WithSpan(ctx, "redis.dial", func(ctx context.Context, span trace.Span) error {
var err error
span.SetAttributes( span.SetAttributes(
label.String("db.connection_string", opt.Addr), label.String("db.connection_string", opt.Addr),
) )
var err error
conn, err = opt.Dialer(ctx, opt.Network, opt.Addr) conn, err = opt.Dialer(ctx, opt.Network, opt.Addr)
if err != nil { if err != nil {
_ = internal.RecordError(ctx, err) _ = internal.RecordError(ctx, err)