SDKの設定

package otel;

import io.opentelemetry.sdk.OpenTelemetrySdk;
import io.opentelemetry.sdk.autoconfigure.AutoConfiguredOpenTelemetrySdk;

public class AutoConfiguredSdk {
  public static OpenTelemetrySdk autoconfiguredSdk() {
    return AutoConfiguredOpenTelemetrySdk.initialize().getOpenTelemetrySdk();
  }
}

package otel;

import io.opentelemetry.sdk.OpenTelemetrySdk;
import io.opentelemetry.sdk.autoconfigure.AutoConfiguredOpenTelemetrySdk;
import java.util.Collections;

public class CustomizedAutoConfiguredSdk {
  public static OpenTelemetrySdk autoconfiguredSdk() {
    return AutoConfiguredOpenTelemetrySdk.builder()
        // オプションでTextMapPropagatorをカスタマイズ。
        .addPropagatorCustomizer((textMapPropagator, configProperties) -> textMapPropagator)
        // オプションでResourceをカスタマイズ。
        .addResourceCustomizer((resource, configProperties) -> resource)
        // オプションでSamplerをカスタマイズ。
        .addSamplerCustomizer((sampler, configProperties) -> sampler)
        // オプションでSpanExporterをカスタマイズ。
        .addSpanExporterCustomizer((spanExporter, configProperties) -> spanExporter)
        // オプションでSpanProcessorをカスタマイズ。
        .addSpanProcessorCustomizer((spanProcessor, configProperties) -> spanProcessor)
        // オプションで追加のプロパティを提供。
        .addPropertiesSupplier(Collections::emptyMap)
        // オプションでConfigPropertiesをカスタマイズ。
        .addPropertiesCustomizer(configProperties -> Collections.emptyMap())
        // オプションでSdkTracerProviderBuilderをカスタマイズ。
        .addTracerProviderCustomizer((builder, configProperties) -> builder)
        // オプションでSdkMeterProviderBuilderをカスタマイズ。
        .addMeterProviderCustomizer((builder, configProperties) -> builder)
        // オプションでMetricExporterをカスタマイズ。
        .addMetricExporterCustomizer((metricExporter, configProperties) -> metricExporter)
        // オプションでMetricReaderをカスタマイズ。
        .addMetricReaderCustomizer((metricReader, configProperties) -> metricReader)
        // オプションでSdkLoggerProviderBuilderをカスタマイズ。
        .addLoggerProviderCustomizer((builder, configProperties) -> builder)
        // オプションでLogRecordExporterをカスタマイズ。
        .addLogRecordExporterCustomizer((logRecordExporter, configProperties) -> logRecordExporter)
        // オプションでLogRecordProcessorをカスタマイズ。
        .addLogRecordProcessorCustomizer((processor, configProperties) -> processor)
        .build()
        .getOpenTelemetrySdk();
  }
}

package otel;

import io.opentelemetry.sdk.autoconfigure.spi.ConfigProperties;
import io.opentelemetry.sdk.autoconfigure.spi.ResourceProvider;
import io.opentelemetry.sdk.resources.Resource;

public class CustomResourceProvider implements ResourceProvider {

  @Override
  public Resource createResource(ConfigProperties config) {
    // リソースに貢献するために呼び出されるコールバック。
    return Resource.builder().put("my.custom.resource.attribute", "abc123").build();
  }

  @Override
  public int order() {
    // オプションで呼び出し順序に影響を与える。
    return 0;
  }
}

package otel;

import io.opentelemetry.sdk.autoconfigure.spi.AutoConfigurationCustomizer;
import io.opentelemetry.sdk.autoconfigure.spi.AutoConfigurationCustomizerProvider;
import java.util.Collections;

public class CustomizerProvider implements AutoConfigurationCustomizerProvider {

  @Override
  public void customize(AutoConfigurationCustomizer customizer) {
    // オプションでTextMapPropagatorをカスタマイズ。
    customizer.addPropagatorCustomizer((textMapPropagator, configProperties) -> textMapPropagator);
    // オプションでResourceをカスタマイズ。
    customizer.addResourceCustomizer((resource, configProperties) -> resource);
    // オプションでSamplerをカスタマイズ。
    customizer.addSamplerCustomizer((sampler, configProperties) -> sampler);
    // オプションでSpanExporterをカスタマイズ。
    customizer.addSpanExporterCustomizer((spanExporter, configProperties) -> spanExporter);
    // オプションでSpanProcessorをカスタマイズ。
    customizer.addSpanProcessorCustomizer((spanProcessor, configProperties) -> spanProcessor);
    // オプションで追加のプロパティを提供。
    customizer.addPropertiesSupplier(Collections::emptyMap);
    // オプションでConfigPropertiesをカスタマイズ。
    customizer.addPropertiesCustomizer(configProperties -> Collections.emptyMap());
    // オプションでSdkTracerProviderBuilderをカスタマイズ。
    customizer.addTracerProviderCustomizer((builder, configProperties) -> builder);
    // オプションでSdkMeterProviderBuilderをカスタマイズ。
    customizer.addMeterProviderCustomizer((builder, configProperties) -> builder);
    // オプションでMetricExporterをカスタマイズ。
    customizer.addMetricExporterCustomizer((metricExporter, configProperties) -> metricExporter);
    // オプションでMetricReaderをカスタマイズ。
    customizer.addMetricReaderCustomizer((metricReader, configProperties) -> metricReader);
    // オプションでSdkLoggerProviderBuilderをカスタマイズ。
    customizer.addLoggerProviderCustomizer((builder, configProperties) -> builder);
    // オプションでLogRecordExporterをカスタマイズ。
    customizer.addLogRecordExporterCustomizer((exporter, configProperties) -> exporter);
    // オプションでLogRecordProcessorをカスタマイズ。
    customizer.addLogRecordProcessorCustomizer((processor, configProperties) -> processor);
  }

  @Override
  public int order() {
    // オプションで呼び出し順序に影響を与える。
    return 0;
  }
}

package otel;

import io.opentelemetry.sdk.autoconfigure.spi.ConfigProperties;
import io.opentelemetry.sdk.autoconfigure.spi.traces.ConfigurableSpanExporterProvider;
import io.opentelemetry.sdk.trace.export.SpanExporter;

public class CustomSpanExporterProvider implements ConfigurableSpanExporterProvider {

  @Override
  public SpanExporter createExporter(ConfigProperties config) {
    // OTEL_TRACES_EXPORTERにgetName()からの値が含まれる場合に呼び出されるコールバック。
    return new CustomSpanExporter();
  }

  @Override
  public String getName() {
    return "custom-exporter";
  }
}

package otel;

import io.opentelemetry.sdk.autoconfigure.spi.ConfigProperties;
import io.opentelemetry.sdk.autoconfigure.spi.metrics.ConfigurableMetricExporterProvider;
import io.opentelemetry.sdk.metrics.export.MetricExporter;

public class CustomMetricExporterProvider implements ConfigurableMetricExporterProvider {

  @Override
  public MetricExporter createExporter(ConfigProperties config) {
    // OTEL_METRICS_EXPORTERにgetName()からの値が含まれる場合に呼び出されるコールバック。
    return new CustomMetricExporter();
  }

  @Override
  public String getName() {
    return "custom-exporter";
  }
}

package otel;

import io.opentelemetry.sdk.autoconfigure.spi.ConfigProperties;
import io.opentelemetry.sdk.autoconfigure.spi.logs.ConfigurableLogRecordExporterProvider;
import io.opentelemetry.sdk.logs.export.LogRecordExporter;

public class CustomLogRecordExporterProvider implements ConfigurableLogRecordExporterProvider {

  @Override
  public LogRecordExporter createExporter(ConfigProperties config) {
    // OTEL_LOGS_EXPORTERにgetName()からの値が含まれる場合に呼び出されるコールバック。
    return new CustomLogRecordExporter();
  }

  @Override
  public String getName() {
    return "custom-exporter";
  }
}

package otel;

import io.opentelemetry.sdk.autoconfigure.spi.ConfigProperties;
import io.opentelemetry.sdk.autoconfigure.spi.traces.ConfigurableSamplerProvider;
import io.opentelemetry.sdk.trace.samplers.Sampler;

public class CustomSamplerProvider implements ConfigurableSamplerProvider {

  @Override
  public Sampler createSampler(ConfigProperties config) {
    // OTEL_TRACES_SAMPLERがgetName()からの値に設定されている場合に呼び出されるコールバック。
    return new CustomSampler();
  }

  @Override
  public String getName() {
    return "custom-sampler";
  }
}

package otel;

import io.opentelemetry.context.propagation.TextMapPropagator;
import io.opentelemetry.sdk.autoconfigure.spi.ConfigProperties;
import io.opentelemetry.sdk.autoconfigure.spi.ConfigurablePropagatorProvider;

public class CustomTextMapPropagatorProvider implements ConfigurablePropagatorProvider {
  @Override
  public TextMapPropagator getPropagator(ConfigProperties config) {
    // OTEL_PROPAGATORSにgetName()からの値が含まれる場合に呼び出されるコールバック。
    return new CustomTextMapPropagator();
  }

  @Override
  public String getName() {
    return "custom-propagator";
  }
}