Package org.elasticsearch.discovery.zen
Class MembershipAction
org.elasticsearch.discovery.zen.MembershipAction
public class MembershipAction
extends
-
Nested Class Summary
Modifier and TypeClassDescriptionstatic interface
static class
static class
static interface
-
Field Summary
Modifier and TypeFieldDescriptionstatic
static
static
-
Constructor Summary
ConstructorDescriptionMembershipAction(TransportService transportService, MembershipAction.MembershipListener listener, <<DiscoveryNode,ClusterState>> joinValidators)
-
Method Summary
Modifier and TypeMethodDescriptionvoid
sendJoinRequestBlocking(DiscoveryNode masterNode, DiscoveryNode node, org.elasticsearch.core.TimeValue timeout)
void
sendLeaveRequest(DiscoveryNode masterNode, DiscoveryNode node)
void
sendLeaveRequestBlocking(DiscoveryNode masterNode, DiscoveryNode node, org.elasticsearch.core.TimeValue timeout)
void
sendValidateJoinRequestBlocking(DiscoveryNode node, ClusterState state, org.elasticsearch.core.TimeValue timeout)
Validates the join request, throwing a failure if it failed.Methods inherited from class java.lang.
, , , , , , , , , ,
-
Field Details
-
DISCOVERY_JOIN_ACTION_NAME
public static final DISCOVERY_JOIN_ACTION_NAME- See Also:
- Constant Field Values
-
DISCOVERY_JOIN_VALIDATE_ACTION_NAME
public static final DISCOVERY_JOIN_VALIDATE_ACTION_NAME- See Also:
- Constant Field Values
-
DISCOVERY_LEAVE_ACTION_NAME
public static final DISCOVERY_LEAVE_ACTION_NAME- See Also:
- Constant Field Values
-
-
Constructor Details
-
MembershipAction
public MembershipAction(TransportService transportService, MembershipAction.MembershipListener listener, <<DiscoveryNode,ClusterState>> joinValidators)
-
-
Method Details
-
sendLeaveRequest
-
sendLeaveRequestBlocking
public void sendLeaveRequestBlocking(DiscoveryNode masterNode, DiscoveryNode node, org.elasticsearch.core.TimeValue timeout) -
sendJoinRequestBlocking
public void sendJoinRequestBlocking(DiscoveryNode masterNode, DiscoveryNode node, org.elasticsearch.core.TimeValue timeout) -
sendValidateJoinRequestBlocking
public void sendValidateJoinRequestBlocking(DiscoveryNode node, ClusterState state, org.elasticsearch.core.TimeValue timeout)Validates the join request, throwing a failure if it failed.
-