|
19 | 19 | import static io.opentelemetry.semconv.DbAttributes.DB_SYSTEM_NAME; |
20 | 20 | import static io.opentelemetry.semconv.ServerAttributes.SERVER_ADDRESS; |
21 | 21 | import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_CONNECTION_STRING; |
| 22 | +import static io.opentelemetry.semconv.incubating.PeerIncubatingAttributes.PEER_SERVICE; |
22 | 23 | import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_NAME; |
23 | 24 | import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_OPERATION; |
24 | 25 | import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_SQL_TABLE; |
@@ -1108,6 +1109,7 @@ void testGetClientInfoException(String query) throws SQLException { |
1108 | 1109 | equalTo( |
1109 | 1110 | DB_CONNECTION_STRING, |
1110 | 1111 | emitStableDatabaseSemconv() ? null : "testdb://localhost"), |
| 1112 | + equalTo(PEER_SERVICE, "test-peer-service"), |
1111 | 1113 | equalTo(SERVER_ADDRESS, "localhost")))); |
1112 | 1114 | } |
1113 | 1115 |
|
@@ -1194,6 +1196,7 @@ void testProduceProperSpanName( |
1194 | 1196 | equalTo(maybeStable(DB_STATEMENT), sanitizedQuery), |
1195 | 1197 | equalTo(maybeStable(DB_OPERATION), operation), |
1196 | 1198 | equalTo(maybeStable(DB_SQL_TABLE), table), |
| 1199 | + equalTo(PEER_SERVICE, "test-peer-service"), |
1197 | 1200 | equalTo(SERVER_ADDRESS, "localhost")))); |
1198 | 1201 | } |
1199 | 1202 |
|
@@ -1317,6 +1320,7 @@ void testHandleRecursiveStatements( |
1317 | 1320 | equalTo(maybeStable(DB_STATEMENT), "SELECT * FROM table"), |
1318 | 1321 | equalTo(maybeStable(DB_OPERATION), "SELECT"), |
1319 | 1322 | equalTo(maybeStable(DB_SQL_TABLE), "table"), |
| 1323 | + equalTo(PEER_SERVICE, "test-peer-service"), |
1320 | 1324 | equalTo(SERVER_ADDRESS, "localhost")))); |
1321 | 1325 | } |
1322 | 1326 |
|
|
0 commit comments