|
32 | 32 | import java.util.Collection; |
33 | 33 | import java.util.LinkedHashSet; |
34 | 34 | import java.util.List; |
35 | | -import java.util.Optional; |
36 | 35 | import java.util.Queue; |
37 | 36 | import java.util.Set; |
38 | 37 | import java.util.concurrent.atomic.AtomicLong; |
39 | 38 |
|
40 | 39 | import io.lettuce.core.ClientOptions; |
41 | | -import io.lettuce.core.ConnectionBuilder; |
42 | 40 | import io.lettuce.core.RedisConnectionException; |
43 | | -import io.lettuce.core.RedisCredentials; |
44 | 41 | import io.lettuce.core.RedisException; |
45 | | -import io.lettuce.core.RedisURI; |
46 | 42 | import io.lettuce.core.api.push.PushListener; |
47 | 43 | import io.lettuce.core.api.push.PushMessage; |
48 | 44 | import io.lettuce.core.datastructure.queue.HashIndexedQueue; |
@@ -491,15 +487,6 @@ private void attachTracing(ChannelHandlerContext ctx, RedisCommand<?, ?, ?> comm |
491 | 487 | Tracer.Span span = tracer.nextSpan(context); |
492 | 488 | span.name(command.getType().toString()); |
493 | 489 |
|
494 | | - if (channel.hasAttr(ConnectionBuilder.REDIS_URI)) { |
495 | | - String redisUriStr = channel.attr(ConnectionBuilder.REDIS_URI).get(); |
496 | | - RedisURI redisURI = RedisURI.create(redisUriStr); |
497 | | - span.tag("server.address", redisURI.toString()); |
498 | | - span.tag("db.namespace", String.valueOf(redisURI.getDatabase())); |
499 | | - span.tag("user.name", Optional.ofNullable(redisURI.getCredentialsProvider().resolveCredentials().block()) |
500 | | - .map(RedisCredentials::getUsername).orElse("")); |
501 | | - } |
502 | | - |
503 | 490 | if (tracedEndpoint != null) { |
504 | 491 | span.remoteEndpoint(tracedEndpoint); |
505 | 492 | } else { |
|
0 commit comments