Class HttpExporter<T extends Marshaler>
- java.lang.Object
-
- io.opentelemetry.exporter.internal.http.HttpExporter<T>
-
public final class HttpExporter<T extends Marshaler> extends java.lang.Object
An exporter for http/protobuf or http/json using a signal-specific Marshaler.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 HttpSender
httpSender
private static java.util.logging.Logger
internalLogger
private java.util.concurrent.atomic.AtomicBoolean
isShutdown
private ThrottlingLogger
logger
private java.lang.String
type
-
Constructor Summary
Constructors Constructor Description HttpExporter(java.lang.String exporterName, java.lang.String type, HttpSender httpSender, java.util.function.Supplier<MeterProvider> meterProviderSupplier, boolean exportAsJson)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description CompletableResultCode
export(T exportRequest, int numItems)
private static java.lang.String
extractErrorStatus(java.lang.String statusMessage, byte[] responseBody)
private void
onError(CompletableResultCode result, int numItems, java.lang.Throwable e)
private void
onResponse(CompletableResultCode result, int numItems, HttpSender.Response httpResponse)
CompletableResultCode
shutdown()
-
-
-
Field Detail
-
internalLogger
private static final java.util.logging.Logger internalLogger
-
logger
private final ThrottlingLogger logger
-
isShutdown
private final java.util.concurrent.atomic.AtomicBoolean isShutdown
-
type
private final java.lang.String type
-
httpSender
private final HttpSender httpSender
-
exporterMetrics
private final ExporterMetrics exporterMetrics
-
-
Constructor Detail
-
HttpExporter
public HttpExporter(java.lang.String exporterName, java.lang.String type, HttpSender httpSender, java.util.function.Supplier<MeterProvider> meterProviderSupplier, boolean exportAsJson)
-
-
Method Detail
-
export
public CompletableResultCode export(T exportRequest, int numItems)
-
onResponse
private void onResponse(CompletableResultCode result, int numItems, HttpSender.Response httpResponse)
-
onError
private void onError(CompletableResultCode result, int numItems, java.lang.Throwable e)
-
shutdown
public CompletableResultCode shutdown()
-
extractErrorStatus
private static java.lang.String extractErrorStatus(java.lang.String statusMessage, @Nullable byte[] responseBody)
-
-