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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
GrpcExporterBuilder<T>	addConstantHeader(String key, 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, TimeUnit unit)
GrpcExporterBuilder<T>	setEndpoint(String endpoint)
GrpcExporterBuilder<T>	setHeadersSupplier(Supplier<Map<String,String>> headerSupplier)
GrpcExporterBuilder<T>	setKeyManagerFromCerts(byte[] privateKeyPem, byte[] certificatePem)
GrpcExporterBuilder<T>	setMeterProvider(Supplier<MeterProvider> meterProviderSupplier)
GrpcExporterBuilder<T>	setRetryPolicy(RetryPolicy retryPolicy)
GrpcExporterBuilder<T>	setSslContext(SSLContext sslContext, X509TrustManager trustManager)
GrpcExporterBuilder<T>	setTimeout(long timeout, TimeUnit unit)
GrpcExporterBuilder<T>	setTimeout(Duration timeout)
GrpcExporterBuilder<T>	setTrustManagerFromCerts(byte[] trustedCertificatesPem)
String	toString()
String	toString(boolean includePrefixAndSuffix)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_CONNECT_TIMEOUT_SECS

public static final long DEFAULT_CONNECT_TIMEOUT_SECS

See Also:

• Constant Field Values

LOGGER

private static final Logger LOGGER

exporterName

private final String exporterName

type

private final String type

grpcEndpointPath

private final String grpcEndpointPath

grpcStubFactory

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

timeoutNanos

private long timeoutNanos

connectTimeoutNanos

private long connectTimeoutNanos

endpoint

private URI endpoint

compressor

@Nullable
private Compressor compressor

constantHeaders

private final Map<String,String> constantHeaders

headerSupplier

private Supplier<Map<String,String>> headerSupplier

tlsConfigHelper

private TlsConfigHelper tlsConfigHelper

retryPolicy

@Nullable
private RetryPolicy retryPolicy

meterProviderSupplier

private Supplier<MeterProvider> meterProviderSupplier

grpcChannel

@Nullable
private Object grpcChannel

Constructor Details

GrpcExporterBuilder

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

Method Details

setChannel

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

setTimeout

public GrpcExporterBuilder<T> setTimeout(long timeout,
 TimeUnit unit)

setTimeout

public GrpcExporterBuilder<T> setTimeout(Duration timeout)

setConnectTimeout

public GrpcExporterBuilder<T> setConnectTimeout(long timeout,
 TimeUnit unit)

setEndpoint

public GrpcExporterBuilder<T> setEndpoint(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(SSLContext sslContext,
 X509TrustManager trustManager)

addConstantHeader

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

setHeadersSupplier

public GrpcExporterBuilder<T> setHeadersSupplier(Supplier<Map<String,String>> headerSupplier)

setRetryPolicy

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

setMeterProvider

public GrpcExporterBuilder<T> setMeterProvider(Supplier<MeterProvider> meterProviderSupplier)

copy

public GrpcExporterBuilder<T> copy()

build

public GrpcExporter<T> build()

toString

public String toString(boolean includePrefixAndSuffix)

toString

public String toString()

Overrides:

toString in class 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.