| 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.