Package io.opentelemetry.exporter.otlp.internal

Class OtlpConfigUtil

java.lang.Object

io.opentelemetry.exporter.otlp.internal.OtlpConfigUtil

public final class OtlpConfigUtil
extends Object

This class is internal and is hence not for public use. Its APIs are unstable and can change at any time.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DATA_TYPE_LOGS
static final String	DATA_TYPE_METRICS
static final String	DATA_TYPE_TRACES
private static final Logger	logger
static final String	PROTOCOL_GRPC
static final String	PROTOCOL_HTTP_PROTOBUF

Constructor Summary

Constructors

Modifier	Constructor	Description
private	OtlpConfigUtil()

Method Summary

Modifier and Type	Method	Description
private static boolean	configContainsKey(ConfigProperties config, String propertyToRead)
static void	configureOtlpExporterBuilder(String dataType, ConfigProperties config, Consumer<String> setEndpoint, BiConsumer<String,String> addHeader, Consumer<String> setCompression, Consumer<Duration> setTimeout, Consumer<byte[]> setTrustedCertificates, BiConsumer<byte[],byte[]> setClientTls, Consumer<RetryPolicy> setRetryPolicy, Consumer<MemoryMode> setMemoryMode)	Invoke the setters with the OTLP configuration for the dataType.
static void	configureOtlpExporterBuilder(String dataType, StructuredConfigProperties config, Consumer<String> setEndpoint, BiConsumer<String,String> addHeader, Consumer<String> setCompression, Consumer<Duration> setTimeout, Consumer<byte[]> setTrustedCertificates, BiConsumer<byte[],byte[]> setClientTls, Consumer<RetryPolicy> setRetryPolicy, Consumer<MemoryMode> setMemoryMode)	Invoke the setters with the OTLP configuration for the dataType.
private static void	configureOtlpHeaders(ConfigProperties config, String dataType, BiConsumer<String,String> addHeader)
private static URL	createUrl(URL context, String spec)
private static String	determinePropertyByType(ConfigProperties config, String prefix, String dataType, String suffix)
static String	getOtlpProtocol(String dataType, ConfigProperties config)	Determine the configured OTLP protocol for the dataType.
static String	getStructuredConfigOtlpProtocol(StructuredConfigProperties config)	Determine the configured OTLP protocol for the dataType.
private static byte[]	readFileBytes(String filePath)
private static String	signalPath(String dataType)
private static URL	validateEndpoint(String endpoint, boolean isHttpProtobuf)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

logger

private static final Logger logger

DATA_TYPE_TRACES

public static final String DATA_TYPE_TRACES

See Also:

• Constant Field Values

DATA_TYPE_METRICS

public static final String DATA_TYPE_METRICS

See Also:

• Constant Field Values

DATA_TYPE_LOGS

public static final String DATA_TYPE_LOGS

See Also:

• Constant Field Values

PROTOCOL_GRPC

public static final String PROTOCOL_GRPC

See Also:

• Constant Field Values

PROTOCOL_HTTP_PROTOBUF

public static final String PROTOCOL_HTTP_PROTOBUF

See Also:

• Constant Field Values

Constructor Details

OtlpConfigUtil

private OtlpConfigUtil()

Method Details

getOtlpProtocol

public static String getOtlpProtocol(String dataType,
 ConfigProperties config)

Determine the configured OTLP protocol for the dataType.

getStructuredConfigOtlpProtocol

public static String getStructuredConfigOtlpProtocol(StructuredConfigProperties config)

Determine the configured OTLP protocol for the dataType.

configureOtlpExporterBuilder

public static void configureOtlpExporterBuilder(String dataType,
 ConfigProperties config,
 Consumer<String> setEndpoint,
 BiConsumer<String,String> addHeader,
 Consumer<String> setCompression,
 Consumer<Duration> setTimeout,
 Consumer<byte[]> setTrustedCertificates,
 BiConsumer<byte[],byte[]> setClientTls,
 Consumer<RetryPolicy> setRetryPolicy,
 Consumer<MemoryMode> setMemoryMode)

Invoke the setters with the OTLP configuration for the dataType.

configureOtlpExporterBuilder

public static void configureOtlpExporterBuilder(String dataType,
 StructuredConfigProperties config,
 Consumer<String> setEndpoint,
 BiConsumer<String,String> addHeader,
 Consumer<String> setCompression,
 Consumer<Duration> setTimeout,
 Consumer<byte[]> setTrustedCertificates,
 BiConsumer<byte[],byte[]> setClientTls,
 Consumer<RetryPolicy> setRetryPolicy,
 Consumer<MemoryMode> setMemoryMode)

Invoke the setters with the OTLP configuration for the dataType.

configureOtlpHeaders

private static void configureOtlpHeaders(ConfigProperties config,
 String dataType,
 BiConsumer<String,String> addHeader)

createUrl

private static URL createUrl(URL context,
 String spec)

validateEndpoint

@Nullable
private static URL validateEndpoint(@Nullable
 String endpoint,
 boolean isHttpProtobuf)

readFileBytes

@Nullable
private static byte[] readFileBytes(@Nullable
 String filePath)

determinePropertyByType

private static String determinePropertyByType(ConfigProperties config,
 String prefix,
 String dataType,
 String suffix)

configContainsKey

private static boolean configContainsKey(ConfigProperties config,
 String propertyToRead)

signalPath

private static String signalPath(String dataType)