public class HttpExporterConfig
extends org.apache.kafka.common.config.AbstractConfig
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
API_KEY |
static java.lang.String |
API_KEY_DOC |
static java.lang.String |
API_SECRET_KEY |
static java.lang.String |
API_SECRET_KEY_DOC |
static java.lang.String |
BUFFER_MAX_BATCH_DURATION_MS |
static java.lang.String |
BUFFER_MAX_BATCH_DURATION_MS_DOC |
static java.lang.String |
BUFFER_MAX_BATCH_SIZE |
static java.lang.String |
BUFFER_MAX_BATCH_SIZE_DOC |
static java.lang.String |
BUFFER_MAX_INFLIGHT_SUBMISSIONS |
static java.lang.String |
BUFFER_MAX_INFLIGHT_SUBMISSIONS_DOC |
static java.lang.String |
BUFFER_MAX_PENDING_BATCHES |
static java.lang.String |
BUFFER_MAX_PENDING_BATCHES_DOC |
static java.lang.String |
CLIENT_BASE_URL |
static java.lang.String |
CLIENT_BASE_URL_DOC |
static java.lang.String |
CLIENT_COMPRESSION |
static java.lang.String |
CLIENT_COMPRESSION_DOC |
static java.lang.String |
CLIENT_CONNECT_TIMEOUT_MS |
static java.lang.String |
CLIENT_CONNECT_TIMEOUT_MS_DOC |
static java.lang.String |
CLIENT_MAX_ATTEMPTS |
static java.lang.String |
CLIENT_MAX_ATTEMPTS_DOC |
static java.lang.String |
CLIENT_REQUEST_TIMEOUT_MS |
static java.lang.String |
CLIENT_REQUEST_TIMEOUT_MS_DOCS |
static java.lang.String |
CLIENT_RETRY_DELAY_SEC |
static java.lang.String |
CLIENT_RETRY_DELAY_SEC_DOC |
static java.lang.String |
PREFIX |
static java.lang.String |
PREFIX_BUFFER |
static java.lang.String |
PREFIX_CLIENT |
static java.lang.String |
PREFIX_PROXY |
static java.lang.String |
PROXY_PASSWORD |
static java.lang.String |
PROXY_PASSWORD_DOC |
static java.lang.String |
PROXY_URL |
static java.lang.String |
PROXY_URL_DOC |
static java.lang.String |
PROXY_USERNAME |
static java.lang.String |
PROXY_USERNAME_DOC |
Constructor and Description |
---|
HttpExporterConfig(java.util.Map<java.lang.String,?> originals) |
Modifier and Type | Method and Description |
---|---|
io.confluent.telemetry.client.BufferingAsyncTelemetryHttpClient.Builder<io.opencensus.proto.metrics.v1.Metric,io.opencensus.proto.agent.metrics.v1.ExportMetricsServiceRequest,io.opencensus.proto.agent.metrics.v1.ExportMetricsServiceResponse> |
getBufferingAsyncClientBuilder() |
io.confluent.telemetry.client.TelemetryHttpClient.Builder<io.opencensus.proto.agent.metrics.v1.ExportMetricsServiceResponse> |
getClientBuilder() |
io.confluent.telemetry.client.CompressionAlgorithm |
getCompressionAlgorithm(java.lang.String key)
Get the compression algorithm.
|
static void |
main(java.lang.String[] args) |
equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, postProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride
public static final java.lang.String PREFIX
public static final java.lang.String PREFIX_BUFFER
public static final java.lang.String PREFIX_CLIENT
public static final java.lang.String PREFIX_PROXY
public static final java.lang.String API_KEY
public static final java.lang.String API_KEY_DOC
public static final java.lang.String API_SECRET_KEY
public static final java.lang.String API_SECRET_KEY_DOC
public static final java.lang.String BUFFER_MAX_BATCH_DURATION_MS
public static final java.lang.String BUFFER_MAX_BATCH_DURATION_MS_DOC
public static final java.lang.String BUFFER_MAX_BATCH_SIZE
public static final java.lang.String BUFFER_MAX_BATCH_SIZE_DOC
public static final java.lang.String BUFFER_MAX_PENDING_BATCHES
public static final java.lang.String BUFFER_MAX_PENDING_BATCHES_DOC
public static final java.lang.String BUFFER_MAX_INFLIGHT_SUBMISSIONS
public static final java.lang.String BUFFER_MAX_INFLIGHT_SUBMISSIONS_DOC
public static final java.lang.String CLIENT_BASE_URL
public static final java.lang.String CLIENT_BASE_URL_DOC
public static final java.lang.String CLIENT_REQUEST_TIMEOUT_MS
public static final java.lang.String CLIENT_REQUEST_TIMEOUT_MS_DOCS
public static final java.lang.String CLIENT_CONNECT_TIMEOUT_MS
public static final java.lang.String CLIENT_CONNECT_TIMEOUT_MS_DOC
public static final java.lang.String CLIENT_MAX_ATTEMPTS
public static final java.lang.String CLIENT_MAX_ATTEMPTS_DOC
public static final java.lang.String CLIENT_RETRY_DELAY_SEC
public static final java.lang.String CLIENT_RETRY_DELAY_SEC_DOC
public static final java.lang.String CLIENT_COMPRESSION
public static final java.lang.String CLIENT_COMPRESSION_DOC
public static final java.lang.String PROXY_URL
public static final java.lang.String PROXY_URL_DOC
public static final java.lang.String PROXY_USERNAME
public static final java.lang.String PROXY_USERNAME_DOC
public static final java.lang.String PROXY_PASSWORD
public static final java.lang.String PROXY_PASSWORD_DOC
public HttpExporterConfig(java.util.Map<java.lang.String,?> originals)
public static void main(java.lang.String[] args)
public io.confluent.telemetry.client.CompressionAlgorithm getCompressionAlgorithm(java.lang.String key)
public io.confluent.telemetry.client.TelemetryHttpClient.Builder<io.opencensus.proto.agent.metrics.v1.ExportMetricsServiceResponse> getClientBuilder()
public io.confluent.telemetry.client.BufferingAsyncTelemetryHttpClient.Builder<io.opencensus.proto.metrics.v1.Metric,io.opencensus.proto.agent.metrics.v1.ExportMetricsServiceRequest,io.opencensus.proto.agent.metrics.v1.ExportMetricsServiceResponse> getBufferingAsyncClientBuilder()