Class GrpcExporter<T extends Marshaler>
- java.lang.Object
-
- io.opentelemetry.exporter.internal.grpc.GrpcExporter<T>
-
public final class GrpcExporter<T extends Marshaler> extends java.lang.Object
Generic gRPC exporter.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 ExporterMetrics
exporterMetrics
private GrpcSender<T>
grpcSender
private static java.util.logging.Logger
internalLogger
private java.util.concurrent.atomic.AtomicBoolean
isShutdown
private java.util.concurrent.atomic.AtomicBoolean
loggedUnimplemented
private ThrottlingLogger
logger
private java.lang.String
type
-
Constructor Summary
Constructors Constructor Description GrpcExporter(java.lang.String exporterName, java.lang.String type, GrpcSender<T> grpcSender, java.util.function.Supplier<MeterProvider> meterProviderSupplier)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description CompletableResultCode
export(T exportRequest, int numItems)
private void
onError(CompletableResultCode result, int numItems, java.lang.Throwable e)
private void
onResponse(CompletableResultCode result, int numItems, GrpcResponse grpcResponse)
CompletableResultCode
shutdown()
-
-
-
Field Detail
-
internalLogger
private static final java.util.logging.Logger internalLogger
-
logger
private final ThrottlingLogger logger
-
loggedUnimplemented
private final java.util.concurrent.atomic.AtomicBoolean loggedUnimplemented
-
isShutdown
private final java.util.concurrent.atomic.AtomicBoolean isShutdown
-
type
private final java.lang.String type
-
grpcSender
private final GrpcSender<T extends Marshaler> grpcSender
-
exporterMetrics
private final ExporterMetrics exporterMetrics
-
-
Constructor Detail
-
GrpcExporter
public GrpcExporter(java.lang.String exporterName, java.lang.String type, GrpcSender<T> grpcSender, java.util.function.Supplier<MeterProvider> meterProviderSupplier)
-
-
Method Detail
-
export
public CompletableResultCode export(T exportRequest, int numItems)
-
onResponse
private void onResponse(CompletableResultCode result, int numItems, GrpcResponse grpcResponse)
-
onError
private void onError(CompletableResultCode result, int numItems, java.lang.Throwable e)
-
shutdown
public CompletableResultCode shutdown()
-
-