Package io.opentelemetry.exporter.internal.grpc

Class GrpcExporterBuilder<T extends Marshaler>

java.lang.Object

io.opentelemetry.exporter.internal.grpc.GrpcExporterBuilder<T>

public class GrpcExporterBuilder<T extends Marshaler>
extends java.lang.Object

A builder for GrpcExporter.

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
private Compressor	compressor
private long	connectTimeoutNanos
private java.util.Map<java.lang.String,java.lang.String>	constantHeaders
static long	DEFAULT_CONNECT_TIMEOUT_SECS
private java.net.URI	endpoint
private java.lang.String	exporterName
private java.lang.Object	grpcChannel
private java.lang.String	grpcEndpointPath
private java.util.function.Supplier<java.util.function.BiFunction<io.grpc.Channel,java.lang.String,MarshalerServiceStub<T,?,?>>>	grpcStubFactory
private java.util.function.Supplier<java.util.Map<java.lang.String,java.lang.String>>	headerSupplier
private static java.util.logging.Logger	LOGGER
private java.util.function.Supplier<MeterProvider>	meterProviderSupplier
private RetryPolicy	retryPolicy
private long	timeoutNanos
private TlsConfigHelper	tlsConfigHelper
private java.lang.String	type

Constructor Summary

Constructors

Constructor	Description
GrpcExporterBuilder(java.lang.String exporterName, java.lang.String type, long defaultTimeoutSecs, java.net.URI defaultEndpoint, java.util.function.Supplier<java.util.function.BiFunction<io.grpc.Channel,java.lang.String,MarshalerServiceStub<T,?,?>>> grpcStubFactory, java.lang.String grpcEndpointPath)

Method Summary

Modifier and Type	Method	Description
GrpcExporterBuilder<T>	addConstantHeader(java.lang.String key, java.lang.String value)
GrpcExporter<T>	build()
GrpcExporterBuilder<T>	copy()
private static GrpcSenderProvider	resolveGrpcSenderProvider()	Resolve the GrpcSenderProvider.
GrpcExporterBuilder<T>	setChannel(io.grpc.ManagedChannel channel)
GrpcExporterBuilder<T>	setCompression(Compressor compressor)
GrpcExporterBuilder<T>	setConnectTimeout(long timeout, java.util.concurrent.TimeUnit unit)
GrpcExporterBuilder<T>	setEndpoint(java.lang.String endpoint)
GrpcExporterBuilder<T>	setHeadersSupplier(java.util.function.Supplier<java.util.Map<java.lang.String,java.lang.String>> headerSupplier)
GrpcExporterBuilder<T>	setKeyManagerFromCerts(byte[] privateKeyPem, byte[] certificatePem)
GrpcExporterBuilder<T>	setMeterProvider(java.util.function.Supplier<MeterProvider> meterProviderSupplier)
GrpcExporterBuilder<T>	setRetryPolicy(RetryPolicy retryPolicy)
GrpcExporterBuilder<T>	setSslContext(javax.net.ssl.SSLContext sslContext, javax.net.ssl.X509TrustManager trustManager)
GrpcExporterBuilder<T>	setTimeout(long timeout, java.util.concurrent.TimeUnit unit)
GrpcExporterBuilder<T>	setTimeout(java.time.Duration timeout)
GrpcExporterBuilder<T>	setTrustManagerFromCerts(byte[] trustedCertificatesPem)
java.lang.String	toString()
java.lang.String	toString(boolean includePrefixAndSuffix)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_CONNECT_TIMEOUT_SECS

public static final long DEFAULT_CONNECT_TIMEOUT_SECS

See Also:

Constant Field Values

LOGGER

private static final java.util.logging.Logger LOGGER

exporterName

private final java.lang.String exporterName

type

private final java.lang.String type

grpcEndpointPath

private final java.lang.String grpcEndpointPath

grpcStubFactory

private final java.util.function.Supplier<java.util.function.BiFunction<io.grpc.Channel,java.lang.String,MarshalerServiceStub<T extends Marshaler,?,?>>> grpcStubFactory

timeoutNanos

private long timeoutNanos

connectTimeoutNanos

private long connectTimeoutNanos

endpoint

private java.net.URI endpoint

compressor

@Nullable
private Compressor compressor

constantHeaders

private final java.util.Map<java.lang.String,java.lang.String> constantHeaders

headerSupplier

private java.util.function.Supplier<java.util.Map<java.lang.String,java.lang.String>> headerSupplier

tlsConfigHelper

private TlsConfigHelper tlsConfigHelper

retryPolicy

@Nullable
private RetryPolicy retryPolicy

meterProviderSupplier

private java.util.function.Supplier<MeterProvider> meterProviderSupplier

grpcChannel

@Nullable
private java.lang.Object grpcChannel

Constructor Detail

GrpcExporterBuilder

public GrpcExporterBuilder(java.lang.String exporterName,
                           java.lang.String type,
                           long defaultTimeoutSecs,
                           java.net.URI defaultEndpoint,
                           java.util.function.Supplier<java.util.function.BiFunction<io.grpc.Channel,java.lang.String,MarshalerServiceStub<T,?,?>>> grpcStubFactory,
                           java.lang.String grpcEndpointPath)

Method Detail

setChannel

public GrpcExporterBuilder<T> setChannel(io.grpc.ManagedChannel channel)

setTimeout

public GrpcExporterBuilder<T> setTimeout(long timeout,
                                         java.util.concurrent.TimeUnit unit)

setTimeout

public GrpcExporterBuilder<T> setTimeout(java.time.Duration timeout)

setConnectTimeout

public GrpcExporterBuilder<T> setConnectTimeout(long timeout,
                                                java.util.concurrent.TimeUnit unit)

setEndpoint

public GrpcExporterBuilder<T> setEndpoint(java.lang.String endpoint)

setCompression

public GrpcExporterBuilder<T> setCompression(@Nullable
                                             Compressor compressor)

setTrustManagerFromCerts

public GrpcExporterBuilder<T> setTrustManagerFromCerts(byte[] trustedCertificatesPem)

setKeyManagerFromCerts

public GrpcExporterBuilder<T> setKeyManagerFromCerts(byte[] privateKeyPem,
                                                     byte[] certificatePem)

setSslContext

public GrpcExporterBuilder<T> setSslContext(javax.net.ssl.SSLContext sslContext,
                                            javax.net.ssl.X509TrustManager trustManager)

addConstantHeader

public GrpcExporterBuilder<T> addConstantHeader(java.lang.String key,
                                                java.lang.String value)

setHeadersSupplier

public GrpcExporterBuilder<T> setHeadersSupplier(java.util.function.Supplier<java.util.Map<java.lang.String,java.lang.String>> headerSupplier)

setRetryPolicy

public GrpcExporterBuilder<T> setRetryPolicy(@Nullable
                                             RetryPolicy retryPolicy)

setMeterProvider

public GrpcExporterBuilder<T> setMeterProvider(java.util.function.Supplier<MeterProvider> meterProviderSupplier)

copy

public GrpcExporterBuilder<T> copy()

build

public GrpcExporter<T> build()

toString

public java.lang.String toString(boolean includePrefixAndSuffix)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

resolveGrpcSenderProvider

private static GrpcSenderProvider resolveGrpcSenderProvider()

Resolve the GrpcSenderProvider.

If no GrpcSenderProvider is available, throw IllegalStateException.

If only one GrpcSenderProvider is available, use it.

If multiple are available and..

• io.opentelemetry.exporter.internal.grpc.GrpcSenderProvider is empty, use the first found.
• io.opentelemetry.exporter.internal.grpc.GrpcSenderProvider is set, use the matching provider. If none match, throw IllegalStateException.