Constructor and Description |
---|
IndexingServiceClient(com.metamx.http.client.HttpClient client,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
ServerDiscoverySelector selector) |
Modifier and Type | Method and Description |
---|---|
com.metamx.common.Pair<String,ServerDiscoverySelector> |
HostSelector.select(Query<T> query) |
Modifier and Type | Method and Description |
---|---|
ServerDiscoverySelector |
ServerDiscoveryFactory.createSelector(String serviceName) |
Modifier and Type | Method and Description |
---|---|
ServerDiscoverySelector |
IndexingServiceDiscoveryModule.getServiceProvider(IndexingServiceSelectorConfig config,
ServerDiscoveryFactory serverDiscoveryFactory) |
Constructor and Description |
---|
RemoteTaskActionClient(Task task,
com.metamx.http.client.HttpClient httpClient,
ServerDiscoverySelector selector,
RetryPolicyFactory retryPolicyFactory,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
RemoteTaskActionClientFactory(com.metamx.http.client.HttpClient httpClient,
ServerDiscoverySelector selector,
RetryPolicyFactory retryPolicyFactory,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
Constructor and Description |
---|
BridgeQuerySegmentWalker(ServerDiscoverySelector brokerSelector,
com.metamx.http.client.HttpClient httpClient,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
Modifier and Type | Method and Description |
---|---|
com.metamx.common.Pair<String,ServerDiscoverySelector> |
TieredBrokerHostSelector.getDefaultLookup() |
com.metamx.common.Pair<String,ServerDiscoverySelector> |
TieredBrokerHostSelector.select(Query<T> query) |
Constructor and Description |
---|
CoordinatorRuleManager(com.metamx.http.client.HttpClient httpClient,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
com.google.common.base.Supplier<TieredBrokerConfig> config,
ServerDiscoverySelector selector) |
Modifier and Type | Method and Description |
---|---|
static boolean |
ServerDiscoveryUtil.isInstanceReady(ServerDiscoverySelector serviceProvider) |
static void |
ServerDiscoveryUtil.waitUntilInstanceReady(ServerDiscoverySelector serviceProvider,
String instanceType) |
Copyright © 2011–2015. All rights reserved.