public class TransportClientNodesService extends AbstractComponent
Modifier and Type | Class and Description |
---|---|
static interface |
TransportClientNodesService.NodeListenerCallback<Response> |
static class |
TransportClientNodesService.RetryListener<Response> |
componentSettings, logger, settings
Constructor and Description |
---|
TransportClientNodesService(Settings settings,
ClusterName clusterName,
TransportService transportService,
ThreadPool threadPool,
Headers headers,
Version version) |
Modifier and Type | Method and Description |
---|---|
TransportClientNodesService |
addTransportAddresses(TransportAddress... transportAddresses) |
void |
close() |
com.google.common.collect.ImmutableList<DiscoveryNode> |
connectedNodes() |
<Response> void |
execute(TransportClientNodesService.NodeListenerCallback<Response> callback,
ActionListener<Response> listener) |
com.google.common.collect.ImmutableList<DiscoveryNode> |
filteredNodes() |
com.google.common.collect.ImmutableList<DiscoveryNode> |
listedNodes() |
TransportClientNodesService |
removeTransportAddress(TransportAddress transportAddress) |
com.google.common.collect.ImmutableList<TransportAddress> |
transportAddresses() |
nodeName
@Inject public TransportClientNodesService(Settings settings, ClusterName clusterName, TransportService transportService, ThreadPool threadPool, Headers headers, Version version)
public com.google.common.collect.ImmutableList<TransportAddress> transportAddresses()
public com.google.common.collect.ImmutableList<DiscoveryNode> connectedNodes()
public com.google.common.collect.ImmutableList<DiscoveryNode> filteredNodes()
public com.google.common.collect.ImmutableList<DiscoveryNode> listedNodes()
public TransportClientNodesService addTransportAddresses(TransportAddress... transportAddresses)
public TransportClientNodesService removeTransportAddress(TransportAddress transportAddress)
public <Response> void execute(TransportClientNodesService.NodeListenerCallback<Response> callback, ActionListener<Response> listener) throws ElasticsearchException
ElasticsearchException
public void close()
Copyright © 2009–2015. All rights reserved.