Package org.elasticsearch.discovery.zen

Class MembershipAction

java.lang.Object

org.elasticsearch.discovery.zen.MembershipAction

public class MembershipAction
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	MembershipAction.JoinCallback
static class	MembershipAction.JoinRequest
static class	MembershipAction.LeaveRequest
static interface	MembershipAction.MembershipListener

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	DISCOVERY_JOIN_ACTION_NAME
static java.lang.String	DISCOVERY_JOIN_VALIDATE_ACTION_NAME
static java.lang.String	DISCOVERY_LEAVE_ACTION_NAME

Constructor Summary

Constructors

Constructor	Description
MembershipAction(TransportService transportService, MembershipAction.MembershipListener listener, java.util.Collection<java.util.function.BiConsumer<DiscoveryNode,ClusterState>> joinValidators)

Method Summary

Modifier and Type	Method	Description
void	sendJoinRequestBlocking(DiscoveryNode masterNode, DiscoveryNode node, org.elasticsearch.common.unit.TimeValue timeout)
void	sendLeaveRequest(DiscoveryNode masterNode, DiscoveryNode node)
void	sendLeaveRequestBlocking(DiscoveryNode masterNode, DiscoveryNode node, org.elasticsearch.common.unit.TimeValue timeout)
void	sendValidateJoinRequestBlocking(DiscoveryNode node, ClusterState state, org.elasticsearch.common.unit.TimeValue timeout)	Validates the join request, throwing a failure if it failed.

Methods inherited from class java.lang.Object

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

Field Details

DISCOVERY_JOIN_ACTION_NAME

public static final java.lang.String DISCOVERY_JOIN_ACTION_NAME

See Also:

Constant Field Values

DISCOVERY_JOIN_VALIDATE_ACTION_NAME

public static final java.lang.String DISCOVERY_JOIN_VALIDATE_ACTION_NAME

See Also:

Constant Field Values

DISCOVERY_LEAVE_ACTION_NAME

public static final java.lang.String DISCOVERY_LEAVE_ACTION_NAME

See Also:

Constant Field Values

Constructor Details

MembershipAction

public MembershipAction(TransportService transportService,
MembershipAction.MembershipListener listener,
java.util.Collection<java.util.function.BiConsumer<DiscoveryNode,ClusterState>> joinValidators)

Method Details

sendLeaveRequest

public void sendLeaveRequest(DiscoveryNode masterNode,
DiscoveryNode node)

sendLeaveRequestBlocking

public void sendLeaveRequestBlocking(DiscoveryNode masterNode,
DiscoveryNode node,
org.elasticsearch.common.unit.TimeValue timeout)

sendJoinRequestBlocking

public void sendJoinRequestBlocking(DiscoveryNode masterNode,
DiscoveryNode node,
org.elasticsearch.common.unit.TimeValue timeout)

sendValidateJoinRequestBlocking

public void sendValidateJoinRequestBlocking(DiscoveryNode node,
ClusterState state,
org.elasticsearch.common.unit.TimeValue timeout)

Validates the join request, throwing a failure if it failed.