Package org.elasticsearch.discovery

Class HandshakingTransportAddressConnector

java.lang.Object

org.elasticsearch.discovery.HandshakingTransportAddressConnector

All Implemented Interfaces:

PeerFinder.TransportAddressConnector

public class HandshakingTransportAddressConnector
extends Object
implements PeerFinder.TransportAddressConnector

Field Summary

Fields

Modifier and Type	Field	Description
static Setting<org.elasticsearch.core.TimeValue>	PROBE_CONNECT_TIMEOUT_SETTING
static Setting<org.elasticsearch.core.TimeValue>	PROBE_HANDSHAKE_TIMEOUT_SETTING

Constructor Summary

Constructors

Constructor	Description
HandshakingTransportAddressConnector(Settings settings, TransportService transportService)

Method Summary

Modifier and Type	Method	Description
void	connectToRemoteMasterNode(TransportAddress transportAddress, ActionListener<DiscoveryNode> listener)	Identify the node at the given address and, if it is a master node and not the local node then establish a full connection to it.

Methods inherited from class java.lang.Object

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

Field Details

PROBE_CONNECT_TIMEOUT_SETTING

public static final Setting<org.elasticsearch.core.TimeValue> PROBE_CONNECT_TIMEOUT_SETTING

PROBE_HANDSHAKE_TIMEOUT_SETTING

public static final Setting<org.elasticsearch.core.TimeValue> PROBE_HANDSHAKE_TIMEOUT_SETTING

Constructor Details

HandshakingTransportAddressConnector

public HandshakingTransportAddressConnector(Settings settings,
 TransportService transportService)

Method Details

connectToRemoteMasterNode

public void connectToRemoteMasterNode(TransportAddress transportAddress,
 ActionListener<DiscoveryNode> listener)

Description copied from interface: PeerFinder.TransportAddressConnector

Identify the node at the given address and, if it is a master node and not the local node then establish a full connection to it.

Specified by:

connectToRemoteMasterNode in interface PeerFinder.TransportAddressConnector