Package org.elasticsearch.cluster.coordination

Class JoinHelper

java.lang.Object

org.elasticsearch.cluster.coordination.JoinHelper

public class JoinHelper
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	JoinHelper.JoinCallback

Field Summary

Fields

Modifier and Type	Field	Description
static String	JOIN_ACTION_NAME
static Setting<org.elasticsearch.core.TimeValue>	JOIN_TIMEOUT_SETTING
static String	START_JOIN_ACTION_NAME
static String	VALIDATE_JOIN_ACTION_NAME

Method Summary

Modifier and Type	Method	Description
void	sendJoinRequest(DiscoveryNode destination, long term, Optional<Join> optionalJoin)
void	sendJoinRequest(DiscoveryNode destination, long term, Optional<Join> optionalJoin, Runnable onCompletion)
void	sendStartJoinRequest(StartJoinRequest startJoinRequest, DiscoveryNode destination)
void	sendValidateJoinRequest(DiscoveryNode node, ClusterState state, ActionListener<TransportResponse.Empty> listener)

Methods inherited from class java.lang.Object

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

Field Details

JOIN_ACTION_NAME

public static final String JOIN_ACTION_NAME

See Also:

Constant Field Values

VALIDATE_JOIN_ACTION_NAME

public static final String VALIDATE_JOIN_ACTION_NAME

See Also:

Constant Field Values

START_JOIN_ACTION_NAME

public static final String START_JOIN_ACTION_NAME

See Also:

Constant Field Values

JOIN_TIMEOUT_SETTING

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

Method Details

sendJoinRequest

public void sendJoinRequest(DiscoveryNode destination,
 long term,
 Optional<Join> optionalJoin)

sendJoinRequest

public void sendJoinRequest(DiscoveryNode destination,
 long term,
 Optional<Join> optionalJoin,
 Runnable onCompletion)

sendStartJoinRequest

public void sendStartJoinRequest(StartJoinRequest startJoinRequest,
 DiscoveryNode destination)

sendValidateJoinRequest

public void sendValidateJoinRequest(DiscoveryNode node,
 ClusterState state,
 ActionListener<TransportResponse.Empty> listener)