Skip to content

Commit d520185

Browse files
committed
use optional instead of providing default for list
1 parent 56280e3 commit d520185

File tree

6 files changed

+10
-20
lines changed

6 files changed

+10
-20
lines changed

instrumentation-api/src/main/java/io/opentelemetry/instrumentation/api/internal/ConfigPropertiesUtil.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@
66
package io.opentelemetry.instrumentation.api.internal;
77

88
import static io.opentelemetry.api.incubator.config.DeclarativeConfigProperties.empty;
9+
import static java.util.Collections.emptyList;
910

1011
import io.opentelemetry.api.OpenTelemetry;
1112
import io.opentelemetry.api.incubator.ExtendedOpenTelemetry;
@@ -125,15 +126,14 @@ public static String getStringOrFallback(
125126
* Returns the list of strings value of the given property name from Declarative Config if
126127
* available, otherwise falls back to system properties and environment variables.
127128
*/
128-
public static List<String> getList(
129-
OpenTelemetry openTelemetry, List<String> defaultValue, String... propertyName) {
129+
public static List<String> getList(OpenTelemetry openTelemetry, String... propertyName) {
130130
DeclarativeConfigProperties node = getDeclarativeConfigNode(openTelemetry, propertyName);
131131
if (node != null) {
132-
return node.getScalarList(leaf(propertyName), String.class, defaultValue);
132+
return node.getScalarList(leaf(propertyName), String.class, emptyList());
133133
}
134134
String value = getString(toSystemProperty(propertyName));
135135
if (value == null) {
136-
return defaultValue;
136+
return emptyList();
137137
}
138138
return filterBlanksAndNulls(value.split(","));
139139
}

instrumentation-api/src/test/java/io/opentelemetry/instrumentation/api/internal/ConfigPropertiesUtilTest.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -199,9 +199,7 @@ void getList_none() {
199199
}
200200

201201
private static void assertList(List<String> expected) {
202-
assertThat(
203-
ConfigPropertiesUtil.getList(
204-
OpenTelemetry.noop(), emptyList(), "test", "property", "list"))
202+
assertThat(ConfigPropertiesUtil.getList(OpenTelemetry.noop(), "test", "property", "list"))
205203
.isEqualTo(expected);
206204
}
207205

@@ -219,7 +217,7 @@ public static Stream<Arguments> listValuesProvider() {
219217
void getList_declarativeConfig(Object property, List<String> expected) {
220218
assertThat(
221219
ConfigPropertiesUtil.getList(
222-
DeclarativeConfiguration.create(model(property)), emptyList(), "foo", "bar"))
220+
DeclarativeConfiguration.create(model(property)), "foo", "bar"))
223221
.isEqualTo(expected);
224222
}
225223
}

instrumentation/aws-sdk/aws-sdk-1.11/library-autoconfigure/src/main/java/io/opentelemetry/instrumentation/awssdk/v1_11/autoconfigure/TracingRequestHandler.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,6 @@
55

66
package io.opentelemetry.instrumentation.awssdk.v1_11.autoconfigure;
77

8-
import static java.util.Collections.emptyList;
9-
108
import com.amazonaws.AmazonWebServiceRequest;
119
import com.amazonaws.Request;
1210
import com.amazonaws.Response;
@@ -35,7 +33,7 @@ private static RequestHandler2 buildDelegate(OpenTelemetry openTelemetry) {
3533
.orElse(false))
3634
.setCapturedHeaders(
3735
ConfigPropertiesUtil.getList(
38-
openTelemetry, emptyList(), "messaging", "experimental", "capture_headers"))
36+
openTelemetry, "messaging", "experimental", "capture_headers"))
3937
.build()
4038
.newRequestHandler();
4139
}

instrumentation/aws-sdk/aws-sdk-2.2/library-autoconfigure/src/main/java/io/opentelemetry/instrumentation/awssdk/v2_2/autoconfigure/AwsSdkSingletons.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,6 @@
55

66
package io.opentelemetry.instrumentation.awssdk.v2_2.autoconfigure;
77

8-
import static java.util.Collections.emptyList;
9-
108
import io.opentelemetry.api.GlobalOpenTelemetry;
119
import io.opentelemetry.instrumentation.api.internal.ConfigPropertiesUtil;
1210
import io.opentelemetry.instrumentation.awssdk.v2_2.AwsSdkTelemetry;
@@ -26,7 +24,7 @@ private static class AwsSdkTelemetryFactory extends AbstractAwsSdkTelemetryFacto
2624
@Override
2725
protected List<String> getCapturedHeaders() {
2826
return ConfigPropertiesUtil.getList(
29-
GlobalOpenTelemetry.get(), emptyList(), "messaging", "experimental", "capture_headers");
27+
GlobalOpenTelemetry.get(), "messaging", "experimental", "capture_headers");
3028
}
3129

3230
@Override

instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/TracingConsumerInterceptor.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,6 @@
55

66
package io.opentelemetry.instrumentation.kafkaclients.v2_6;
77

8-
import static java.util.Collections.emptyList;
9-
108
import com.google.errorprone.annotations.CanIgnoreReturnValue;
119
import io.opentelemetry.api.GlobalOpenTelemetry;
1210
import io.opentelemetry.api.OpenTelemetry;
@@ -45,7 +43,7 @@ public class TracingConsumerInterceptor<K, V> implements ConsumerInterceptor<K,
4543
.orElse(false))
4644
.setCapturedHeaders(
4745
ConfigPropertiesUtil.getList(
48-
openTelemetry, emptyList(), "messaging", "experimental", "capture_headers"))
46+
openTelemetry, "messaging", "experimental", "capture_headers"))
4947
.build();
5048
}
5149

instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/TracingProducerInterceptor.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,6 @@
55

66
package io.opentelemetry.instrumentation.kafkaclients.v2_6;
77

8-
import static java.util.Collections.emptyList;
9-
108
import com.google.errorprone.annotations.CanIgnoreReturnValue;
119
import io.opentelemetry.api.GlobalOpenTelemetry;
1210
import io.opentelemetry.api.OpenTelemetry;
@@ -37,7 +35,7 @@ public class TracingProducerInterceptor<K, V> implements ProducerInterceptor<K,
3735
KafkaTelemetry.builder(openTelemetry)
3836
.setCapturedHeaders(
3937
ConfigPropertiesUtil.getList(
40-
openTelemetry, emptyList(), "messaging", "experimental", "capture_headers"))
38+
openTelemetry, "messaging", "experimental", "capture_headers"))
4139
.build();
4240
}
4341

0 commit comments

Comments
 (0)