Skip to content

Commit 7a23016

Browse files
trasktrask
committed
more
1 parent 00bc62e commit 7a23016

File tree

9 files changed

+38
-8
lines changed
  • instrumentation
    • elasticsearch
      • elasticsearch-api-client-7.16/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/elasticsearch/apiclient
      • elasticsearch-rest-5.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/elasticsearch/rest/v5_0
      • elasticsearch-rest-6.4/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/elasticsearch/rest/v6_4
      • elasticsearch-rest-7.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/elasticsearch/rest/v7_0
    • kubernetes-client-7.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/kubernetesclient
    • lettuce
    • opensearch/opensearch-rest-common/testing/src/main/java/io/opentelemetry/javaagent/instrumentation/opensearch/rest
    • vertx/vertx-redis-client-4.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/vertx/v4_0/redis

9 files changed

+38
-8
lines changed

‎instrumentation/elasticsearch/elasticsearch-api-client-7.16/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/elasticsearch/apiclient/ElasticsearchClientTest.java‎

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_OPERATION_NAME;
2121
import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_SYSTEM;
2222
import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_SYSTEM_NAME;
23+
import static io.opentelemetry.semconv.incubating.PeerIncubatingAttributes.PEER_SERVICE;
2324
import static org.assertj.core.api.Assertions.assertThat;
2425

2526
import co.elastic.clients.elasticsearch.ElasticsearchAsyncClient;
@@ -118,6 +119,7 @@ void elasticsearchStatus() throws IOException {
118119
equalTo(SERVER_PORT, httpHost.getPort()),
119120
equalTo(HTTP_REQUEST_METHOD, "GET"),
120121
equalTo(NETWORK_PROTOCOL_VERSION, "1.1"),
122+
equalTo(PEER_SERVICE, "test-peer-service"),
121123
equalTo(URL_FULL, httpHost.toURI() + "/"),
122124
equalTo(HTTP_RESPONSE_STATUS_CODE, 200L))));
123125
}
@@ -159,6 +161,7 @@ void elasticsearchIndex() throws IOException {
159161
equalTo(SERVER_PORT, httpHost.getPort()),
160162
equalTo(HTTP_REQUEST_METHOD, "PUT"),
161163
equalTo(NETWORK_PROTOCOL_VERSION, "1.1"),
164+
equalTo(PEER_SERVICE, "test-peer-service"),
162165
equalTo(
163166
URL_FULL,
164167
httpHost.toURI() + "/test-index/_doc/test-id?timeout=10s"),
@@ -220,6 +223,7 @@ void elasticsearchStatusAsync() throws Exception {
220223
equalTo(SERVER_PORT, httpHost.getPort()),
221224
equalTo(HTTP_REQUEST_METHOD, "GET"),
222225
equalTo(NETWORK_PROTOCOL_VERSION, "1.1"),
226+
equalTo(PEER_SERVICE, "test-peer-service"),
223227
equalTo(URL_FULL, httpHost.toURI() + "/"),
224228
equalTo(HTTP_RESPONSE_STATUS_CODE, 200L)),
225229
span ->

‎instrumentation/elasticsearch/elasticsearch-rest-5.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/elasticsearch/rest/v5_0/ElasticsearchRest5Test.java‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616
import static io.opentelemetry.semconv.UrlAttributes.URL_FULL;
1717
import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_SYSTEM;
1818
import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_SYSTEM_NAME;
19+
import static io.opentelemetry.semconv.incubating.PeerIncubatingAttributes.PEER_SERVICE;
1920
import static org.assertj.core.api.Assertions.assertThat;
2021

2122
import com.fasterxml.jackson.databind.ObjectMapper;
@@ -117,6 +118,7 @@ void elasticsearchStatus() throws IOException {
117118
equalTo(SERVER_PORT, httpHost.getPort()),
118119
equalTo(HTTP_REQUEST_METHOD, "GET"),
119120
equalTo(NETWORK_PROTOCOL_VERSION, "1.1"),
121+
equalTo(PEER_SERVICE, "test-peer-service"),
120122
equalTo(URL_FULL, httpHost.toURI() + "/_cluster/health"),
121123
equalTo(HTTP_RESPONSE_STATUS_CODE, 200))));
122124

@@ -191,6 +193,7 @@ public void onFailure(Exception e) {
191193
equalTo(SERVER_PORT, httpHost.getPort()),
192194
equalTo(HTTP_REQUEST_METHOD, "GET"),
193195
equalTo(NETWORK_PROTOCOL_VERSION, "1.1"),
196+
equalTo(PEER_SERVICE, "test-peer-service"),
194197
equalTo(URL_FULL, httpHost.toURI() + "/_cluster/health"),
195198
equalTo(HTTP_RESPONSE_STATUS_CODE, 200)),
196199
span ->

‎instrumentation/elasticsearch/elasticsearch-rest-6.4/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/elasticsearch/rest/v6_4/ElasticsearchRest6Test.java‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616
import static io.opentelemetry.semconv.UrlAttributes.URL_FULL;
1717
import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_SYSTEM;
1818
import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_SYSTEM_NAME;
19+
import static io.opentelemetry.semconv.incubating.PeerIncubatingAttributes.PEER_SERVICE;
1920
import static org.assertj.core.api.Assertions.assertThat;
2021

2122
import com.fasterxml.jackson.databind.ObjectMapper;
@@ -107,6 +108,7 @@ void elasticsearchStatus() throws IOException {
107108
equalTo(SERVER_PORT, httpHost.getPort()),
108109
equalTo(HTTP_REQUEST_METHOD, "GET"),
109110
equalTo(NETWORK_PROTOCOL_VERSION, "1.1"),
111+
equalTo(PEER_SERVICE, "test-peer-service"),
110112
equalTo(URL_FULL, httpHost.toURI() + "/_cluster/health"),
111113
equalTo(HTTP_RESPONSE_STATUS_CODE, 200L))));
112114

@@ -181,6 +183,7 @@ public void onFailure(Exception e) {
181183
equalTo(SERVER_PORT, httpHost.getPort()),
182184
equalTo(HTTP_REQUEST_METHOD, "GET"),
183185
equalTo(NETWORK_PROTOCOL_VERSION, "1.1"),
186+
equalTo(PEER_SERVICE, "test-peer-service"),
184187
equalTo(URL_FULL, httpHost.toURI() + "/_cluster/health"),
185188
equalTo(HTTP_RESPONSE_STATUS_CODE, 200)),
186189
span ->

‎instrumentation/elasticsearch/elasticsearch-rest-7.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/elasticsearch/rest/v7_0/ElasticsearchRest7Test.java‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717
import static io.opentelemetry.semconv.UrlAttributes.URL_FULL;
1818
import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_SYSTEM;
1919
import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_SYSTEM_NAME;
20+
import static io.opentelemetry.semconv.incubating.PeerIncubatingAttributes.PEER_SERVICE;
2021
import static org.assertj.core.api.Assertions.assertThat;
2122

2223
import com.fasterxml.jackson.databind.ObjectMapper;
@@ -108,6 +109,7 @@ void elasticsearchStatus() throws Exception {
108109
equalTo(SERVER_PORT, httpHost.getPort()),
109110
equalTo(HTTP_REQUEST_METHOD, "GET"),
110111
equalTo(NETWORK_PROTOCOL_VERSION, "1.1"),
112+
equalTo(PEER_SERVICE, "test-peer-service"),
111113
equalTo(URL_FULL, httpHost.toURI() + "/_cluster/health"),
112114
equalTo(HTTP_RESPONSE_STATUS_CODE, 200L))));
113115

@@ -185,6 +187,7 @@ public void onFailure(Exception e) {
185187
equalTo(SERVER_PORT, httpHost.getPort()),
186188
equalTo(HTTP_REQUEST_METHOD, "GET"),
187189
equalTo(NETWORK_PROTOCOL_VERSION, "1.1"),
190+
equalTo(PEER_SERVICE, "test-peer-service"),
188191
equalTo(URL_FULL, httpHost.toURI() + "/_cluster/health"),
189192
equalTo(HTTP_RESPONSE_STATUS_CODE, 200L)),
190193
span ->

‎instrumentation/kubernetes-client-7.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/kubernetesclient/KubernetesClientTest.java‎

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@
1313
import static io.opentelemetry.semconv.ServerAttributes.SERVER_ADDRESS;
1414
import static io.opentelemetry.semconv.ServerAttributes.SERVER_PORT;
1515
import static io.opentelemetry.semconv.UrlAttributes.URL_FULL;
16+
import static io.opentelemetry.semconv.incubating.PeerIncubatingAttributes.PEER_SERVICE;
1617
import static org.assertj.core.api.Assertions.assertThat;
1718

1819
import io.kubernetes.client.openapi.ApiCallback;
@@ -89,6 +90,7 @@ void synchronousCall() throws ApiException {
8990
equalTo(HTTP_RESPONSE_STATUS_CODE, 200),
9091
equalTo(SERVER_ADDRESS, "127.0.0.1"),
9192
equalTo(SERVER_PORT, mockWebServer.httpPort()),
93+
equalTo(PEER_SERVICE, "test-peer-service"),
9294
equalTo(
9395
AttributeKey.stringKey("kubernetes-client.namespace"), "namespace"),
9496
equalTo(AttributeKey.stringKey("kubernetes-client.name"), "name"))));
@@ -136,6 +138,7 @@ void handleErrorsInSyncCall() {
136138
equalTo(HTTP_RESPONSE_STATUS_CODE, 451),
137139
equalTo(SERVER_ADDRESS, "127.0.0.1"),
138140
equalTo(SERVER_PORT, mockWebServer.httpPort()),
141+
equalTo(PEER_SERVICE, "test-peer-service"),
139142
equalTo(ERROR_TYPE, "451"),
140143
equalTo(
141144
AttributeKey.stringKey("kubernetes-client.namespace"), "namespace"),
@@ -190,6 +193,7 @@ public void onSuccess(
190193
equalTo(HTTP_RESPONSE_STATUS_CODE, 200),
191194
equalTo(SERVER_ADDRESS, "127.0.0.1"),
192195
equalTo(SERVER_PORT, mockWebServer.httpPort()),
196+
equalTo(PEER_SERVICE, "test-peer-service"),
193197
equalTo(
194198
AttributeKey.stringKey("kubernetes-client.namespace"), "namespace"),
195199
equalTo(AttributeKey.stringKey("kubernetes-client.name"), "name")),
@@ -251,6 +255,7 @@ public void onFailure(
251255
equalTo(HTTP_RESPONSE_STATUS_CODE, 451),
252256
equalTo(SERVER_ADDRESS, "127.0.0.1"),
253257
equalTo(SERVER_PORT, mockWebServer.httpPort()),
258+
equalTo(PEER_SERVICE, "test-peer-service"),
254259
equalTo(ERROR_TYPE, "451"),
255260
equalTo(
256261
AttributeKey.stringKey("kubernetes-client.namespace"), "namespace"),

‎instrumentation/lettuce/lettuce-4.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/lettuce/v4_0/LettuceAsyncClientTest.java‎

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@
1313
import static io.opentelemetry.semconv.ServerAttributes.SERVER_PORT;
1414
import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_OPERATION;
1515
import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_SYSTEM;
16+
import static io.opentelemetry.semconv.incubating.PeerIncubatingAttributes.PEER_SERVICE;
1617
import static org.assertj.core.api.Assertions.assertThat;
1718
import static org.assertj.core.api.Assertions.catchException;
1819
import static org.assertj.core.api.Assertions.catchThrowable;
@@ -152,9 +153,10 @@ void testConnectUsingGetOnConnectionFuture() {
152153
span.hasName("CONNECT")
153154
.hasKind(SpanKind.CLIENT)
154155
.hasAttributesSatisfyingExactly(
156+
equalTo(maybeStable(DB_SYSTEM), "redis"),
157+
equalTo(PEER_SERVICE, "test-peer-service"),
155158
equalTo(SERVER_ADDRESS, host),
156-
equalTo(SERVER_PORT, port),
157-
equalTo(maybeStable(DB_SYSTEM), "redis"))));
159+
equalTo(SERVER_PORT, port))));
158160
}
159161

160162
@Test
@@ -180,9 +182,10 @@ void testExceptionInsideTheConnectionFuture() {
180182
.hasStatus(StatusData.error())
181183
.hasException(exception)
182184
.hasAttributesSatisfyingExactly(
185+
equalTo(maybeStable(DB_SYSTEM), "redis"),
186+
equalTo(PEER_SERVICE, "test-peer-service"),
183187
equalTo(SERVER_ADDRESS, host),
184-
equalTo(SERVER_PORT, incorrectPort),
185-
equalTo(maybeStable(DB_SYSTEM), "redis"))));
188+
equalTo(SERVER_PORT, incorrectPort))));
186189
}
187190

188191
@Test

‎instrumentation/lettuce/lettuce-5.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/lettuce/v5_0/LettuceAsyncClientTest.java‎

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@
1515
import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_OPERATION;
1616
import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_STATEMENT;
1717
import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_SYSTEM;
18+
import static io.opentelemetry.semconv.incubating.PeerIncubatingAttributes.PEER_SERVICE;
1819
import static org.assertj.core.api.Assertions.assertThat;
1920
import static org.assertj.core.api.Assertions.catchException;
2021
import static org.assertj.core.api.Assertions.catchThrowable;
@@ -124,9 +125,10 @@ void testConnectUsingGetOnConnectionFuture() throws ExecutionException, Interrup
124125
span.hasName("CONNECT")
125126
.hasKind(SpanKind.CLIENT)
126127
.hasAttributesSatisfyingExactly(
128+
equalTo(maybeStable(DB_SYSTEM), "redis"),
129+
equalTo(PEER_SERVICE, "test-peer-service"),
127130
equalTo(SERVER_ADDRESS, host),
128-
equalTo(SERVER_PORT, port),
129-
equalTo(maybeStable(DB_SYSTEM), "redis"))));
131+
equalTo(SERVER_PORT, port))));
130132
}
131133

132134
@SuppressWarnings("deprecation") // RedisURI constructor
@@ -155,9 +157,10 @@ void testConnectExceptionInsideTheConnectionFuture() {
155157
.hasKind(SpanKind.CLIENT)
156158
.hasStatus(StatusData.error())
157159
.hasAttributesSatisfyingExactly(
160+
equalTo(maybeStable(DB_SYSTEM), "redis"),
161+
equalTo(PEER_SERVICE, "test-peer-service"),
158162
equalTo(SERVER_ADDRESS, host),
159-
equalTo(SERVER_PORT, incorrectPort),
160-
equalTo(maybeStable(DB_SYSTEM), "redis"))
163+
equalTo(SERVER_PORT, incorrectPort))
161164
.hasEventsSatisfyingExactly(
162165
event ->
163166
event

‎instrumentation/opensearch/opensearch-rest-common/testing/src/main/java/io/opentelemetry/javaagent/instrumentation/opensearch/rest/AbstractOpenSearchRestTest.java‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_OPERATION;
2020
import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_STATEMENT;
2121
import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_SYSTEM;
22+
import static io.opentelemetry.semconv.incubating.PeerIncubatingAttributes.PEER_SERVICE;
2223
import static org.assertj.core.api.Assertions.assertThat;
2324

2425
import io.opentelemetry.api.trace.SpanKind;
@@ -99,6 +100,7 @@ void shouldGetStatusWithTraces() throws IOException {
99100
equalTo(SERVER_ADDRESS, httpHost.getHost()),
100101
equalTo(SERVER_PORT, httpHost.getPort()),
101102
equalTo(HTTP_REQUEST_METHOD, "GET"),
103+
equalTo(PEER_SERVICE, "test-peer-service"),
102104
equalTo(URL_FULL, httpHost + "/_cluster/health"),
103105
equalTo(HTTP_RESPONSE_STATUS_CODE, 200L))));
104106
}
@@ -169,6 +171,7 @@ public void onFailure(Exception e) {
169171
equalTo(SERVER_ADDRESS, httpHost.getHost()),
170172
equalTo(SERVER_PORT, httpHost.getPort()),
171173
equalTo(HTTP_REQUEST_METHOD, "GET"),
174+
equalTo(PEER_SERVICE, "test-peer-service"),
172175
equalTo(URL_FULL, httpHost + "/_cluster/health"),
173176
equalTo(HTTP_RESPONSE_STATUS_CODE, 200L)),
174177
span ->

‎instrumentation/vertx/vertx-redis-client-4.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/vertx/v4_0/redis/VertxRedisClientTest.java‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_REDIS_DATABASE_INDEX;
2020
import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_STATEMENT;
2121
import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_SYSTEM;
22+
import static io.opentelemetry.semconv.incubating.PeerIncubatingAttributes.PEER_SERVICE;
2223
import static org.assertj.core.api.Assertions.assertThat;
2324

2425
import io.opentelemetry.api.trace.SpanKind;
@@ -226,6 +227,7 @@ private static AttributeAssertion[] redisSpanAttributes(String operation, String
226227
equalTo(DB_NAMESPACE, "1"),
227228
equalTo(SERVER_ADDRESS, host),
228229
equalTo(SERVER_PORT, port),
230+
equalTo(PEER_SERVICE, "test-peer-service"),
229231
equalTo(NETWORK_PEER_PORT, port),
230232
equalTo(NETWORK_PEER_ADDRESS, ip)
231233
};
@@ -237,6 +239,7 @@ private static AttributeAssertion[] redisSpanAttributes(String operation, String
237239
equalTo(DB_REDIS_DATABASE_INDEX, 1),
238240
equalTo(SERVER_ADDRESS, host),
239241
equalTo(SERVER_PORT, port),
242+
equalTo(PEER_SERVICE, "test-peer-service"),
240243
equalTo(NETWORK_PEER_PORT, port),
241244
equalTo(NETWORK_PEER_ADDRESS, ip)
242245
};

0 commit comments

Comments
 (0)