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 forGrpcExporter
.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
All Methods Static Methods Instance Methods Concrete Methods 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 theGrpcSenderProvider
.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)
-
-
-
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 classjava.lang.Object
-
resolveGrpcSenderProvider
private static GrpcSenderProvider resolveGrpcSenderProvider()
Resolve theGrpcSenderProvider
.If no
GrpcSenderProvider
is available, throwIllegalStateException
.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, throwIllegalStateException
.
-
-