-
Notifications
You must be signed in to change notification settings - Fork 2.7k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Clean up code of OpenTelemetryProducer
There are two reasons to do this: * We are adding more and more customizations to OpenTelemetry thus making the OpenTelemetryProducer grow and more (see #34920 for example). * If we are going to move OpenTelemetryProducer to a synthetic bean, cutting down on the injection points will lead to a lot less boilerplate
- Loading branch information
Showing
3 changed files
with
181 additions
and
116 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
167 changes: 167 additions & 0 deletions
167
...ava/io/quarkus/opentelemetry/runtime/AutoConfiguredOpenTelemetrySdkBuilderCustomizer.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,167 @@ | ||
| package io.quarkus.opentelemetry.runtime; | ||
|
|
||
| import static java.lang.Boolean.TRUE; | ||
| import static java.util.Collections.emptyList; | ||
|
|
||
| import java.util.ArrayList; | ||
| import java.util.List; | ||
| import java.util.function.BiFunction; | ||
|
|
||
| import jakarta.enterprise.inject.Any; | ||
| import jakarta.enterprise.inject.Instance; | ||
| import jakarta.inject.Singleton; | ||
|
|
||
| import io.opentelemetry.sdk.autoconfigure.AutoConfiguredOpenTelemetrySdkBuilder; | ||
| import io.opentelemetry.sdk.autoconfigure.spi.ConfigProperties; | ||
| import io.opentelemetry.sdk.resources.Resource; | ||
| import io.opentelemetry.sdk.trace.IdGenerator; | ||
| import io.opentelemetry.sdk.trace.SdkTracerProviderBuilder; | ||
| import io.opentelemetry.sdk.trace.SpanProcessor; | ||
| import io.opentelemetry.sdk.trace.samplers.Sampler; | ||
| import io.quarkus.arc.All; | ||
| import io.quarkus.opentelemetry.runtime.config.build.OTelBuildConfig; | ||
| import io.quarkus.opentelemetry.runtime.config.runtime.OTelRuntimeConfig; | ||
| import io.quarkus.opentelemetry.runtime.exporter.otlp.RemoveableLateBoundBatchSpanProcessor; | ||
| import io.quarkus.opentelemetry.runtime.tracing.DelayedAttributes; | ||
| import io.quarkus.opentelemetry.runtime.tracing.DropTargetsSampler; | ||
| import io.quarkus.opentelemetry.runtime.tracing.TracerRecorder; | ||
| import io.quarkus.opentelemetry.runtime.tracing.TracerUtil; | ||
| import io.quarkus.runtime.ApplicationConfig; | ||
|
|
||
| public interface AutoConfiguredOpenTelemetrySdkBuilderCustomizer { | ||
|
|
||
| void customize(AutoConfiguredOpenTelemetrySdkBuilder builder); | ||
|
|
||
| @Singleton | ||
| final class ResourceCustomizer implements AutoConfiguredOpenTelemetrySdkBuilderCustomizer { | ||
|
|
||
| private final ApplicationConfig appConfig; | ||
| private final OTelBuildConfig oTelBuildConfig; | ||
| private final OTelRuntimeConfig oTelRuntimeConfig; | ||
| private final Instance<DelayedAttributes> delayedAttributes; | ||
| private final List<Resource> resources; | ||
|
|
||
| public ResourceCustomizer(ApplicationConfig appConfig, | ||
| OTelBuildConfig oTelBuildConfig, | ||
| OTelRuntimeConfig oTelRuntimeConfig, | ||
| @Any Instance<DelayedAttributes> delayedAttributes, | ||
| @All List<Resource> resources) { | ||
| this.appConfig = appConfig; | ||
| this.oTelBuildConfig = oTelBuildConfig; | ||
| this.oTelRuntimeConfig = oTelRuntimeConfig; | ||
| this.delayedAttributes = delayedAttributes; | ||
| this.resources = resources; | ||
| } | ||
|
|
||
| @Override | ||
| public void customize(AutoConfiguredOpenTelemetrySdkBuilder builder) { | ||
| builder.addResourceCustomizer(new BiFunction<>() { | ||
| @Override | ||
| public Resource apply(Resource existingResource, ConfigProperties configProperties) { | ||
| if (oTelBuildConfig.traces().enabled().orElse(TRUE)) { | ||
| Resource consolidatedResource = existingResource.merge( | ||
| Resource.create(delayedAttributes.get())); | ||
|
|
||
| // if user explicitly set 'otel.service.name', make sure we don't override it with defaults | ||
| // inside resource customizer | ||
| String serviceName = oTelRuntimeConfig | ||
| .serviceName() | ||
| .filter(sn -> !sn.equals(appConfig.name.orElse("unset"))) | ||
| .orElse(null); | ||
|
|
||
| // Merge resource instances with env attributes | ||
| Resource resource = resources.stream() | ||
| .reduce(Resource.empty(), Resource::merge) | ||
| .merge(TracerUtil.mapResourceAttributes( | ||
| oTelRuntimeConfig.resourceAttributes().orElse(emptyList()), | ||
| serviceName)); // from properties | ||
| return consolidatedResource.merge(resource); | ||
| } else { | ||
| return Resource.builder().build(); | ||
| } | ||
| } | ||
| }); | ||
| } | ||
| } | ||
|
|
||
| @Singleton | ||
| final class SamplerCustomizer implements AutoConfiguredOpenTelemetrySdkBuilderCustomizer { | ||
|
|
||
| private final OTelBuildConfig oTelBuildConfig; | ||
| private final OTelRuntimeConfig oTelRuntimeConfig; | ||
| private final List<Sampler> sampler; | ||
|
|
||
| public SamplerCustomizer(OTelBuildConfig oTelBuildConfig, | ||
| OTelRuntimeConfig oTelRuntimeConfig, | ||
| @All List<Sampler> sampler) { | ||
| this.oTelBuildConfig = oTelBuildConfig; | ||
| this.oTelRuntimeConfig = oTelRuntimeConfig; | ||
| this.sampler = sampler; | ||
| } | ||
|
|
||
| @Override | ||
| public void customize(AutoConfiguredOpenTelemetrySdkBuilder builder) { | ||
| builder.addSamplerCustomizer(new BiFunction<>() { | ||
| @Override | ||
| public Sampler apply(Sampler existingSampler, ConfigProperties configProperties) { | ||
| if (oTelBuildConfig.traces().enabled().orElse(TRUE)) { | ||
| final Sampler effectiveSampler = sampler.stream().findFirst() | ||
| .map(Sampler.class::cast)// use CDI if it exists | ||
| .orElse(existingSampler); | ||
|
|
||
| //collect default filtering targets (Needed for all samplers) | ||
| List<String> dropTargets = new ArrayList<>(); | ||
| if (oTelRuntimeConfig.traces().suppressNonApplicationUris()) {//default is true | ||
| dropTargets.addAll(TracerRecorder.dropNonApplicationUriTargets); | ||
| } | ||
| if (!oTelRuntimeConfig.traces().includeStaticResources()) {// default is false | ||
| dropTargets.addAll(TracerRecorder.dropStaticResourceTargets); | ||
| } | ||
|
|
||
| // make sure dropped targets are not sampled | ||
| if (!dropTargets.isEmpty()) { | ||
| return new DropTargetsSampler(effectiveSampler, dropTargets); | ||
| } else { | ||
| return effectiveSampler; | ||
| } | ||
| } else { | ||
| return Sampler.alwaysOff(); | ||
| } | ||
| } | ||
| }); | ||
| } | ||
| } | ||
|
|
||
| @Singleton | ||
| final class TracerProviderCustomizer implements AutoConfiguredOpenTelemetrySdkBuilderCustomizer { | ||
|
|
||
| private final OTelBuildConfig oTelBuildConfig; | ||
| private final List<IdGenerator> idGenerator; | ||
| private final List<SpanProcessor> spanProcessors; | ||
|
|
||
| public TracerProviderCustomizer(OTelBuildConfig oTelBuildConfig, | ||
| @All List<IdGenerator> idGenerator, | ||
| @All List<SpanProcessor> spanProcessors) { | ||
| this.oTelBuildConfig = oTelBuildConfig; | ||
| this.idGenerator = idGenerator; | ||
| this.spanProcessors = spanProcessors; | ||
| } | ||
|
|
||
| @Override | ||
| public void customize(AutoConfiguredOpenTelemetrySdkBuilder builder) { | ||
| builder.addTracerProviderCustomizer( | ||
| new BiFunction<>() { | ||
| @Override | ||
| public SdkTracerProviderBuilder apply(SdkTracerProviderBuilder builder, | ||
| ConfigProperties configProperties) { | ||
| if (oTelBuildConfig.traces().enabled().orElse(TRUE)) { | ||
| idGenerator.stream().findFirst().ifPresent(builder::setIdGenerator); // from cdi | ||
| spanProcessors.stream().filter(sp -> !(sp instanceof RemoveableLateBoundBatchSpanProcessor)) | ||
| .forEach(builder::addSpanProcessor); | ||
| } | ||
| return builder; | ||
| } | ||
| }); | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters