File tree 4 files changed +9
-4
lines changed
elasticsearch/elasticsearch-transport-common/testing/src/main/java/io/opentelemetry/javaagent/instrumentation/elasticsearch/transport
lettuce/lettuce-5.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/lettuce/v5_0
spymemcached-2.12/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/spymemcached
vertx/vertx-sql-client-4.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/vertx/v4_0/sql
4 files changed +9
-4
lines changed Original file line number Diff line number Diff line change 11
11
import static io .opentelemetry .instrumentation .testing .util .TelemetryDataUtil .orderByRootSpanName ;
12
12
import static io .opentelemetry .sdk .testing .assertj .OpenTelemetryAssertions .equalTo ;
13
13
import static io .opentelemetry .sdk .testing .assertj .OpenTelemetryAssertions .satisfies ;
14
+ import static io .opentelemetry .semconv .ErrorAttributes .ERROR_TYPE ;
14
15
import static io .opentelemetry .semconv .ExceptionAttributes .EXCEPTION_TYPE ;
15
16
import static io .opentelemetry .semconv .NetworkAttributes .NETWORK_PEER_ADDRESS ;
16
17
import static io .opentelemetry .semconv .NetworkAttributes .NETWORK_PEER_PORT ;
@@ -145,6 +146,8 @@ void elasticsearchError(Runnable action) {
145
146
maybeStable (DB_SYSTEM ),
146
147
DbIncubatingAttributes .DbSystemIncubatingValues .ELASTICSEARCH ),
147
148
equalTo (maybeStable (DB_OPERATION ), "GetAction" ),
149
+ equalTo (
150
+ ERROR_TYPE , "org.elasticsearch.transport.RemoteTransportException" ),
148
151
equalTo (ELASTICSEARCH_ACTION , "GetAction" ),
149
152
equalTo (ELASTICSEARCH_REQUEST , "GetRequest" ),
150
153
equalTo (ELASTICSEARCH_REQUEST_INDICES , "invalid-index" )),
Original file line number Diff line number Diff line change 9
9
import static io .opentelemetry .instrumentation .testing .junit .db .SemconvStabilityUtil .maybeStable ;
10
10
import static io .opentelemetry .sdk .testing .assertj .OpenTelemetryAssertions .equalTo ;
11
11
import static io .opentelemetry .sdk .testing .assertj .OpenTelemetryAssertions .satisfies ;
12
+ import static io .opentelemetry .semconv .ErrorAttributes .ERROR_TYPE ;
12
13
import static io .opentelemetry .semconv .ServerAttributes .SERVER_ADDRESS ;
13
14
import static io .opentelemetry .semconv .ServerAttributes .SERVER_PORT ;
14
15
import static io .opentelemetry .semconv .incubating .DbIncubatingAttributes .DB_OPERATION ;
@@ -423,7 +424,8 @@ void testCommandCompletesExceptionally() {
423
424
.hasAttributesSatisfyingExactly (
424
425
equalTo (maybeStable (DB_SYSTEM ), "redis" ),
425
426
equalTo (maybeStable (DB_STATEMENT ), "DEL key1 key2" ),
426
- equalTo (maybeStable (DB_OPERATION ), "DEL" ))));
427
+ equalTo (maybeStable (DB_OPERATION ), "DEL" ),
428
+ equalTo (maybeStable (ERROR_TYPE ), "java.lang.IllegalStateException" ))));
427
429
}
428
430
429
431
@ Test
Original file line number Diff line number Diff line change @@ -884,9 +884,7 @@ void decrException() {
884
884
maybeStable (DB_SYSTEM ),
885
885
DbIncubatingAttributes .DbSystemIncubatingValues .MEMCACHED ),
886
886
equalTo (maybeStable (DB_OPERATION ), "decr" ),
887
- equalTo (
888
- ERROR_TYPE ,
889
- "net.spy.memcached.internal.CheckedOperationTimeoutException" ))));
887
+ equalTo (ERROR_TYPE , "java.lang.IllegalArgumentException" ))));
890
888
}
891
889
892
890
@ Test
Original file line number Diff line number Diff line change 9
9
import static io .opentelemetry .instrumentation .testing .junit .db .SemconvStabilityUtil .maybeStable ;
10
10
import static io .opentelemetry .sdk .testing .assertj .OpenTelemetryAssertions .equalTo ;
11
11
import static io .opentelemetry .sdk .testing .assertj .OpenTelemetryAssertions .satisfies ;
12
+ import static io .opentelemetry .semconv .ErrorAttributes .ERROR_TYPE ;
12
13
import static io .opentelemetry .semconv .ExceptionAttributes .EXCEPTION_MESSAGE ;
13
14
import static io .opentelemetry .semconv .ExceptionAttributes .EXCEPTION_STACKTRACE ;
14
15
import static io .opentelemetry .semconv .ExceptionAttributes .EXCEPTION_TYPE ;
@@ -199,6 +200,7 @@ void testInvalidQuery() throws Exception {
199
200
equalTo (maybeStable (DB_NAME ), DB ),
200
201
equalTo (DB_USER , emitStableDatabaseSemconv () ? null : USER_DB ),
201
202
equalTo (maybeStable (DB_STATEMENT ), "invalid" ),
203
+ equalTo (ERROR_TYPE , "io.vertx.pgclient.PgException" ),
202
204
equalTo (SERVER_ADDRESS , host ),
203
205
equalTo (SERVER_PORT , port )),
204
206
span ->
You can’t perform that action at this time.
0 commit comments