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