Package io.confluent.telemetry.exporter.http

Class HttpClientFactory

java.lang.Object

io.confluent.telemetry.exporter.http.HttpClientFactory

public class HttpClientFactory
extends Object

Constructor Summary

Constructors

Constructor	Description
HttpClientFactory()

Method Summary

Modifier and Type	Method	Description
io.confluent.telemetry.client.BufferingAsyncClient<ExportableMetric,io.opentelemetry.proto.collector.metrics.v1.ExportMetricsServiceResponse>	get(HttpExporterConfigWrapper configWrapper)	Retrieves or creates a BufferingAsyncClient instance based on the provided configuration wrapper.
static HttpClientFactory	getInstance()

Methods inherited from class java.lang.Object

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

Constructor Details

HttpClientFactory

public HttpClientFactory()

Method Details

getInstance

public static HttpClientFactory getInstance()

get

public io.confluent.telemetry.client.BufferingAsyncClient<ExportableMetric,io.opentelemetry.proto.collector.metrics.v1.ExportMetricsServiceResponse> get(HttpExporterConfigWrapper configWrapper)

Retrieves or creates a BufferingAsyncClient instance based on the provided configuration wrapper.

If the HttpExporterConfigWrapper contains a non-null HttpClientConfig, this method attempts to reuse an existing CloseableReferenceTracker for the client name specified in the HttpClientConfig. If no tracker exists, or if the existing tracker's configuration has changed and the tracker is marked for replacement, a new tracker is created and stored, replacing the old one to allow GC to collect it.

The returned BufferingAsyncClient is a proxy that tracks references, ensuring that the underlying static client is closed only when all references (leases) are released.

If the HttpExporterConfigWrapper does not contain a HttpClientConfig (i.e., it's null), a new, non-static BufferingAsyncClient is created directly by calling HttpExporterConfigWrapper.createBufferingClient().

Parameters:

configWrapper - The wrapper containing configuration for the HTTP exporter and its client.

Returns:

A BufferingAsyncClient instance, potentially wrapped in a ReferenceTrackingProxy.