Package io.opentelemetry.exporter.internal.grpc

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

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()

Methods inherited from class java.lang.Object

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

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()