org.elasticsearch.client.transport
Class TransportClientNodesService

java.lang.Object
  org.elasticsearch.common.component.AbstractComponent
      org.elasticsearch.client.transport.TransportClientNodesService

public class TransportClientNodesService
extends AbstractComponent

Nested Class Summary

static interface	TransportClientNodesService.NodeCallback<T>
static interface	TransportClientNodesService.NodeListenerCallback<Response>
static class	TransportClientNodesService.RetryListener<Response>

Field Summary

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

componentSettings, logger, settings

Constructor Summary

TransportClientNodesService(Settings settings, ClusterName clusterName, TransportService transportService, ThreadPool threadPool)

Method Summary

TransportClientNodesService	addTransportAddresses(TransportAddress... transportAddresses)
void	close()
com.google.common.collect.ImmutableList<DiscoveryNode>	connectedNodes()
<T> T	execute(TransportClientNodesService.NodeCallback<T> callback)
<Response> void	execute(TransportClientNodesService.NodeListenerCallback<Response> callback, ActionListener<Response> listener)
com.google.common.collect.ImmutableList<DiscoveryNode>	listedNodes()
TransportClientNodesService	removeTransportAddress(TransportAddress transportAddress)
com.google.common.collect.ImmutableList<TransportAddress>	transportAddresses()

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

nodeName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TransportClientNodesService

@Inject
public TransportClientNodesService(Settings settings,
                                          ClusterName clusterName,
                                          TransportService transportService,
                                          ThreadPool threadPool)

Method Detail

transportAddresses

public com.google.common.collect.ImmutableList<TransportAddress> transportAddresses()

connectedNodes

public com.google.common.collect.ImmutableList<DiscoveryNode> connectedNodes()

listedNodes

public com.google.common.collect.ImmutableList<DiscoveryNode> listedNodes()

addTransportAddresses

public TransportClientNodesService addTransportAddresses(TransportAddress... transportAddresses)

removeTransportAddress

public TransportClientNodesService removeTransportAddress(TransportAddress transportAddress)

execute

public <T> T execute(TransportClientNodesService.NodeCallback<T> callback)
          throws ElasticSearchException

Throws:

ElasticSearchException

execute

public <Response> void execute(TransportClientNodesService.NodeListenerCallback<Response> callback,
                               ActionListener<Response> listener)
             throws ElasticSearchException

Throws:

ElasticSearchException

close

public void close()