|
33 | 33 | import io.opentelemetry.sdk.autoconfigure.spi.ConfigProperties; |
34 | 34 | import io.opentelemetry.sdk.autoconfigure.spi.ConfigurationException; |
35 | 35 | import io.opentelemetry.sdk.autoconfigure.spi.internal.DefaultConfigProperties; |
| 36 | +import io.opentelemetry.sdk.extension.incubator.ExtendedOpenTelemetrySdk; |
| 37 | +import io.opentelemetry.sdk.extension.incubator.fileconfig.DeclarativeConfiguration; |
| 38 | +import io.opentelemetry.sdk.extension.incubator.fileconfig.SdkConfigProvider; |
| 39 | +import io.opentelemetry.sdk.extension.incubator.fileconfig.internal.model.OpenTelemetryConfigurationModel; |
36 | 40 | import io.opentelemetry.sdk.resources.Resource; |
37 | | -import io.opentelemetry.sdk.trace.SdkTracerProvider; |
38 | 41 | import io.opentelemetry.sdk.trace.export.SimpleSpanProcessor; |
39 | 42 | import java.io.IOException; |
40 | 43 | import java.nio.charset.StandardCharsets; |
@@ -114,19 +117,22 @@ void configFile_fileNotFound() { |
114 | 117 | } |
115 | 118 |
|
116 | 119 | @Test |
117 | | - void configFile_Valid() { |
| 120 | + void configFile_Valid() throws IOException { |
118 | 121 | ConfigProperties config = |
119 | 122 | DefaultConfigProperties.createFromMap( |
120 | 123 | Collections.singletonMap("otel.experimental.config.file", configFilePath.toString())); |
| 124 | + OpenTelemetryConfigurationModel model = |
| 125 | + DeclarativeConfiguration.parse(Files.newInputStream(configFilePath.toFile().toPath())); |
121 | 126 | OpenTelemetrySdk expectedSdk = |
122 | | - OpenTelemetrySdk.builder() |
123 | | - .setTracerProvider( |
124 | | - SdkTracerProvider.builder() |
125 | | - .setResource( |
126 | | - Resource.getDefault().toBuilder().put("service.name", "test").build()) |
127 | | - .addSpanProcessor(SimpleSpanProcessor.create(LoggingSpanExporter.create())) |
128 | | - .build()) |
| 127 | + ExtendedOpenTelemetrySdk.builder() |
| 128 | + .setConfigProvider(SdkConfigProvider.create(model)) |
| 129 | + .withTracerProvider( |
| 130 | + b -> |
| 131 | + b.setResource( |
| 132 | + Resource.getDefault().toBuilder().put("service.name", "test").build()) |
| 133 | + .addSpanProcessor(SimpleSpanProcessor.create(LoggingSpanExporter.create()))) |
129 | 134 | .build(); |
| 135 | + |
130 | 136 | cleanup.addCloseable(expectedSdk); |
131 | 137 | AutoConfiguredOpenTelemetrySdkBuilder builder = spy(AutoConfiguredOpenTelemetrySdk.builder()); |
132 | 138 | Thread thread = new Thread(); |
|
0 commit comments