public class HttpExporterConfig extends ExporterConfig
Modifier and Type | Class and Description |
---|---|
static class |
HttpExporterConfig.URIValidator |
ExporterConfig.ExporterType
ENABLED_CONFIG, ENABLED_CONFIG_DOC, EVENTS_ENABLED_CONFIG, EVENTS_ENABLED_CONFIG_DEFAULT, EVENTS_ENABLED_CONFIG_DOC, METRICS_ENABLED_CONFIG, METRICS_ENABLED_CONFIG_DEFAULT, METRICS_ENABLED_CONFIG_DOC, METRICS_INCLUDE_CONFIG, METRICS_INCLUDE_CONFIG_DOC, RECONFIGURABLES, REMOTE_CONFIGURABLE_CONFIG, REMOTE_CONFIGURABLE_CONFIG_DEFAULT, REMOTE_CONFIGURABLE_CONFIG_DOC, TYPE_CONFIG, TYPE_CONFIG_DOC
Constructor and Description |
---|
HttpExporterConfig(String name,
Map<String,?> originals) |
HttpExporterConfig(String name,
Map<String,?> originals,
boolean doLog) |
Modifier and Type | Method and Description |
---|---|
Boolean |
canEmitMetrics() |
<T,S> io.confluent.telemetry.client.TelemetryHttpClient.Builder<T,S> |
configureClientDefaults(io.confluent.telemetry.client.TelemetryHttpClient.Builder<T,S> builder) |
io.confluent.telemetry.client.BufferingAsyncTelemetryHttpClient.Builder<io.opentelemetry.proto.metrics.v1.Metric,io.opentelemetry.proto.collector.metrics.v1.ExportMetricsServiceRequest,io.opentelemetry.proto.collector.metrics.v1.ExportMetricsServiceResponse> |
getBufferingAsyncClientBuilder() |
io.confluent.telemetry.client.CompressionAlgorithm |
getCompressionAlgorithm(String key)
Get the compression algorithm.
|
io.confluent.telemetry.client.Credentials |
getCredentials() |
io.confluent.telemetry.client.ProxyConfig |
getProxyConfig() |
static void |
main(String[] args) |
buildMetricsPredicate, getName, getType, isEnabled, isMetricsEnabled, isRemoteConfigurable, parseType, reconfigure
documentationOf, equals, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride
public static final String PREFIX_BUFFER
public static final String PREFIX_CLIENT
public static final String PREFIX_PROXY
public static final String API_KEY
public static final String API_KEY_DOC
public static final String API_SECRET
public static final String API_SECRET_DOC
public static final String BUFFER_MAX_BATCH_DURATION_MS
public static final String BUFFER_MAX_BATCH_DURATION_MS_DOC
public static final String BUFFER_MAX_BATCH_SIZE
public static final String BUFFER_MAX_BATCH_SIZE_DOC
public static final String BUFFER_MAX_PENDING_BATCHES
public static final String BUFFER_MAX_PENDING_BATCHES_DOC
public static final String BUFFER_MAX_INFLIGHT_SUBMISSIONS
public static final String BUFFER_MAX_INFLIGHT_SUBMISSIONS_DOC
public static final String CLIENT_BASE_URL
public static final String CLIENT_BASE_URL_DOC
public static final String CLIENT_METRICS_PATH
public static final String CLIENT_METRICS_PATH_DOC
public static final String CLIENT_METRICS_PATH_DEFAULT
public static final String CLIENT_REQUEST_TIMEOUT_MS
public static final String CLIENT_REQUEST_TIMEOUT_MS_DOCS
public static final String CLIENT_CONNECT_TIMEOUT_MS
public static final String CLIENT_CONNECT_TIMEOUT_MS_DOC
public static final String CLIENT_MAX_ATTEMPTS
public static final String CLIENT_MAX_ATTEMPTS_DOC
public static final String CLIENT_RETRY_DELAY_SEC
public static final String CLIENT_RETRY_DELAY_SEC_DOC
public static final String CLIENT_COMPRESSION
public static final String CLIENT_COMPRESSION_DOC
public static final String CLIENT_CONTENT_TYPE
public static final String CLIENT_CONTENT_TYPE_DOC
public static final String PROXY_URL
public static final String PROXY_URL_DOC
public static final String PROXY_USERNAME
public static final String PROXY_USERNAME_DOC
public static final String PROXY_PASSWORD
public static final String PROXY_PASSWORD_DOC
public static void main(String[] args)
public io.confluent.telemetry.client.Credentials getCredentials()
public io.confluent.telemetry.client.ProxyConfig getProxyConfig()
public io.confluent.telemetry.client.CompressionAlgorithm getCompressionAlgorithm(String key)
public <T,S> io.confluent.telemetry.client.TelemetryHttpClient.Builder<T,S> configureClientDefaults(io.confluent.telemetry.client.TelemetryHttpClient.Builder<T,S> builder)
public io.confluent.telemetry.client.BufferingAsyncTelemetryHttpClient.Builder<io.opentelemetry.proto.metrics.v1.Metric,io.opentelemetry.proto.collector.metrics.v1.ExportMetricsServiceRequest,io.opentelemetry.proto.collector.metrics.v1.ExportMetricsServiceResponse> getBufferingAsyncClientBuilder()
public Boolean canEmitMetrics()