Skip to content

Commit 83ce10e

Browse files
committed
Add Apolloconfig Inst
#12787
1 parent f75200a commit 83ce10e

File tree

2 files changed

+17
-21
lines changed

2 files changed

+17
-21
lines changed

instrumentation/apolloconfig-apolloclient-1.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/apolloconfig/apolloclient/v1_0/ApolloConfigSingletons.java

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -16,12 +16,12 @@
1616
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
1717
import io.opentelemetry.instrumentation.api.instrumenter.Instrumenter;
1818
import io.opentelemetry.instrumentation.api.instrumenter.SpanKindExtractor;
19-
import io.opentelemetry.instrumentation.api.instrumenter.SpanStatusExtractor;
2019
import javax.annotation.Nullable;
2120

2221
public final class ApolloConfigSingletons {
2322

24-
private static final String NAME = "io.opentelemetry.apolloconfig-apolloclient-1.0";
23+
private static final String INSTRUMENTATION_NAME =
24+
"io.opentelemetry.apolloconfig-apolloclient-1.0";
2525
private static final Instrumenter<String, Void> INSTRUMENTER;
2626

2727
private static final AttributeKey<String> CONFIG_NS_ATTRIBUTE_KEY = stringKey("config.namespace");
@@ -51,17 +51,17 @@ public void onEnd(
5151
@Nullable Throwable error) {}
5252
};
5353

54-
SpanStatusExtractor<String, Void> spanStatusExtractor =
55-
(spanStatusBuilder, request, unused, error) -> {
56-
if (error != null) {
57-
spanStatusBuilder.setStatus(StatusCode.ERROR);
58-
}
59-
};
60-
6154
INSTRUMENTER =
6255
Instrumenter.<String, Void>builder(
63-
GlobalOpenTelemetry.get(), NAME, (event) -> "Apollo Config Repository Change")
64-
.setSpanStatusExtractor(spanStatusExtractor)
56+
GlobalOpenTelemetry.get(),
57+
INSTRUMENTATION_NAME,
58+
(event) -> "Apollo Config Repository Change")
59+
.setSpanStatusExtractor(
60+
(spanStatusBuilder, request, unused, error) -> {
61+
if (error != null) {
62+
spanStatusBuilder.setStatus(StatusCode.ERROR);
63+
}
64+
})
6565
.addAttributesExtractor(attributesExtractor)
6666
.buildInstrumenter(SpanKindExtractor.alwaysClient());
6767
}

instrumentation/apolloconfig-apolloclient-1.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/apolloconfig/apolloclient/v1_0/ApolloRepositoryChangeTest.java

Lines changed: 6 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@
66
package io.opentelemetry.javaagent.instrumentation.apolloconfig.apolloclient.v1_0;
77

88
import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.equalTo;
9+
import static java.util.Collections.singletonList;
910

1011
import com.ctrip.framework.apollo.enums.ConfigSourceType;
1112
import com.ctrip.framework.apollo.internals.AbstractConfigRepository;
@@ -15,9 +16,6 @@
1516
import io.opentelemetry.api.trace.SpanKind;
1617
import io.opentelemetry.instrumentation.testing.junit.AgentInstrumentationExtension;
1718
import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
18-
import io.opentelemetry.sdk.testing.assertj.AttributeAssertion;
19-
import java.util.ArrayList;
20-
import java.util.List;
2119
import java.util.Properties;
2220
import org.junit.jupiter.api.Test;
2321
import org.junit.jupiter.api.extension.RegisterExtension;
@@ -28,7 +26,7 @@ class ApolloRepositoryChangeTest {
2826
private static final InstrumentationExtension testing = AgentInstrumentationExtension.create();
2927

3028
@Test
31-
void test() {
29+
void fireRepositoryChangeTest() {
3230
String namespace = "application";
3331

3432
TestConfigRepository testConfigRepository = new TestConfigRepository(namespace);
@@ -39,17 +37,15 @@ void test() {
3937
}
4038

4139
private static void checkRepositoryChange(String namespace) {
42-
String spanName = "Apollo Config Repository Change";
43-
List<AttributeAssertion> attributeAssertions = new ArrayList<>();
44-
attributeAssertions.add(equalTo(AttributeKey.stringKey("config.namespace"), namespace));
45-
4640
testing.waitAndAssertTraces(
4741
trace ->
4842
trace.hasSpansSatisfyingExactly(
4943
span ->
5044
span.hasKind(SpanKind.CLIENT)
51-
.hasName(spanName)
52-
.hasAttributesSatisfyingExactly(attributeAssertions)));
45+
.hasName("Apollo Config Repository Change")
46+
.hasAttributesSatisfyingExactly(
47+
singletonList(
48+
equalTo(AttributeKey.stringKey("config.namespace"), namespace)))));
5349
}
5450

5551
static class TestConfigRepository extends AbstractConfigRepository {

0 commit comments

Comments
 (0)