Constructor and Description |
---|
BrokerServerView(QueryToolChestWarehouse warehouse,
QueryWatcher queryWatcher,
com.fasterxml.jackson.databind.ObjectMapper smileMapper,
HttpClient httpClient,
FilteredServerInventoryView baseView,
TierSelectorStrategy tierSelectorStrategy,
ServiceEmitter emitter,
BrokerSegmentWatcherConfig segmentWatcherConfig) |
DirectDruidClient(QueryToolChestWarehouse warehouse,
QueryWatcher queryWatcher,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
HttpClient httpClient,
String scheme,
String host,
ServiceEmitter emitter) |
HttpServerInventoryView(com.fasterxml.jackson.databind.ObjectMapper smileMapper,
HttpClient httpClient,
DruidNodeDiscoveryProvider druidNodeDiscoveryProvider,
com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> defaultFilter,
HttpServerInventoryViewConfig config) |
Constructor and Description |
---|
DruidLeaderClient(HttpClient httpClient,
DruidNodeDiscoveryProvider druidNodeDiscoveryProvider,
String nodeTypeToWatch,
String leaderRequestPath,
ServerDiscoverySelector serverDiscoverySelector) |
Modifier and Type | Method and Description |
---|---|
DruidLeaderClient |
IndexingServiceDiscoveryModule.getLeaderHttpClient(HttpClient httpClient,
DruidNodeDiscoveryProvider druidNodeDiscoveryProvider,
ServerDiscoverySelector serverDiscoverySelector) |
DruidLeaderClient |
CoordinatorDiscoveryModule.getLeaderHttpClient(HttpClient httpClient,
DruidNodeDiscoveryProvider druidNodeDiscoveryProvider,
ServerDiscoverySelector serverDiscoverySelector) |
Modifier and Type | Method and Description |
---|---|
HttpClient |
HttpClientModule.HttpClientProvider.get() |
Constructor and Description |
---|
KafkaIndexTaskClient(HttpClient httpClient,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
TaskInfoProvider taskInfoProvider,
String dataSource,
int numThreads,
org.joda.time.Duration httpTimeout,
long numRetries) |
KafkaIndexTaskClientFactory(HttpClient httpClient,
com.fasterxml.jackson.databind.ObjectMapper mapper) |
Constructor and Description |
---|
RemoteTaskRunner(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
RemoteTaskRunnerConfig config,
IndexerZkConfig indexerZkConfig,
org.apache.curator.framework.CuratorFramework cf,
PathChildrenCacheFactory.Builder pathChildrenCacheFactory,
HttpClient httpClient,
com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef,
ProvisioningStrategy<WorkerTaskRunner> provisioningStrategy) |
RemoteTaskRunnerFactory(org.apache.curator.framework.CuratorFramework curator,
RemoteTaskRunnerConfig remoteTaskRunnerConfig,
IndexerZkConfig zkPaths,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
HttpClient httpClient,
com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef,
ProvisioningSchedulerConfig provisioningSchedulerConfig,
ProvisioningStrategy provisioningStrategy) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractHttpClient |
class |
CredentialedHttpClient |
class |
EnforceSslHttpClient |
class |
NettyHttpClient |
Modifier and Type | Method and Description |
---|---|
static HttpClient |
HttpClientInit.createClient(HttpClientConfig config,
Lifecycle lifecycle) |
static HttpClient |
HttpClientInit.createClient(ResourcePoolConfig config,
SSLContext sslContext,
Lifecycle lifecycle)
Deprecated.
|
HttpClient |
NettyHttpClient.withReadTimeout(org.joda.time.Duration readTimeout) |
Constructor and Description |
---|
CredentialedHttpClient(Credentials creds,
HttpClient delegate) |
EnforceSslHttpClient(HttpClient delegate) |
Constructor and Description |
---|
CommonCacheNotifier(Map<String,BasicAuthDBConfig> itemConfigMap,
DruidNodeDiscoveryProvider discoveryProvider,
HttpClient httpClient,
String baseUrl,
String callerName) |
Modifier and Type | Method and Description |
---|---|
HttpClient |
BasicHTTPEscalator.createEscalatedClient(HttpClient baseClient) |
Modifier and Type | Method and Description |
---|---|
HttpClient |
BasicHTTPEscalator.createEscalatedClient(HttpClient baseClient) |
Constructor and Description |
---|
CoordinatorBasicAuthenticatorCacheNotifier(AuthenticatorMapper authenticatorMapper,
DruidNodeDiscoveryProvider discoveryProvider,
HttpClient httpClient) |
Constructor and Description |
---|
CoordinatorBasicAuthorizerCacheNotifier(AuthorizerMapper authorizerMapper,
DruidNodeDiscoveryProvider discoveryProvider,
HttpClient httpClient) |
Modifier and Type | Class and Description |
---|---|
class |
KerberosHttpClient |
Modifier and Type | Method and Description |
---|---|
HttpClient |
KerberosEscalator.createEscalatedClient(HttpClient baseClient) |
Modifier and Type | Method and Description |
---|---|
HttpClient |
KerberosEscalator.createEscalatedClient(HttpClient baseClient) |
Constructor and Description |
---|
KerberosHttpClient(HttpClient delegate,
String internalClientPrincipal,
String internalClientKeytab) |
Constructor and Description |
---|
HttpLoadQueuePeon(String baseUrl,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
HttpClient httpClient,
DruidCoordinatorConfig config,
ScheduledExecutorService processingExecutor,
ExecutorService callBackExecutor) |
LoadQueueTaskMaster(org.apache.curator.framework.CuratorFramework curator,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
ScheduledExecutorService peonExec,
ExecutorService callbackExec,
DruidCoordinatorConfig config,
HttpClient httpClient,
ZkPathsConfig zkPaths) |
Constructor and Description |
---|
LookupCoordinatorManager(HttpClient httpClient,
DruidNodeDiscoveryProvider druidNodeDiscoveryProvider,
com.fasterxml.jackson.databind.ObjectMapper smileMapper,
JacksonConfigManager configManager,
LookupCoordinatorManagerConfig lookupCoordinatorManagerConfig) |
LookupsCommunicator(HttpClient httpClient,
LookupCoordinatorManagerConfig lookupCoordinatorManagerConfig,
com.fasterxml.jackson.databind.ObjectMapper smileMapper) |
Modifier and Type | Method and Description |
---|---|
HttpClient |
NoopEscalator.createEscalatedClient(HttpClient baseClient) |
HttpClient |
Escalator.createEscalatedClient(HttpClient baseClient)
Return a client that sends requests with the format/information necessary to authenticate successfully
against this Escalator's authentication scheme using the identity of the internal system user.
|
Modifier and Type | Method and Description |
---|---|
HttpClient |
NoopEscalator.createEscalatedClient(HttpClient baseClient) |
HttpClient |
Escalator.createEscalatedClient(HttpClient baseClient)
Return a client that sends requests with the format/information necessary to authenticate successfully
against this Escalator's authentication scheme using the identity of the internal system user.
|
Constructor and Description |
---|
EventReceiverFirehoseTestClient(String host,
String chatID,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
HttpClient httpClient,
com.fasterxml.jackson.databind.ObjectMapper smileMapper) |
Modifier and Type | Method and Description |
---|---|
HttpClient |
DruidTestModule.getHttpClient(IntegrationTestingConfig config,
Lifecycle lifecycle,
HttpClient delegate) |
Modifier and Type | Method and Description |
---|---|
HttpClient |
DruidTestModule.getHttpClient(IntegrationTestingConfig config,
Lifecycle lifecycle,
HttpClient delegate) |
Copyright © 2011–2018. All rights reserved.