Package org.elasticsearch.discovery.zen

Class MembershipAction

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.discovery.zen.MembershipAction

public class MembershipAction
extends AbstractComponent

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

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

deprecationLogger, logger, settings

Constructor Summary

Constructors

Constructor	Description
MembershipAction(Settings settings, 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, TimeValue timeout)
void	sendLeaveRequest(DiscoveryNode masterNode, DiscoveryNode node)
void	sendLeaveRequestBlocking(DiscoveryNode masterNode, DiscoveryNode node, TimeValue timeout)
void	sendValidateJoinRequestBlocking(DiscoveryNode node, ClusterState state, TimeValue timeout)	Validates the join request, throwing a failure if it failed.

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

Field Detail

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 Detail

MembershipAction

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

Method Detail

sendLeaveRequest

public void sendLeaveRequest(DiscoveryNode masterNode,
                             DiscoveryNode node)

sendLeaveRequestBlocking

public void sendLeaveRequestBlocking(DiscoveryNode masterNode,
                                     DiscoveryNode node,
                                     TimeValue timeout)

sendJoinRequestBlocking

public void sendJoinRequestBlocking(DiscoveryNode masterNode,
                                    DiscoveryNode node,
                                    TimeValue timeout)

sendValidateJoinRequestBlocking

public void sendValidateJoinRequestBlocking(DiscoveryNode node,
                                            ClusterState state,
                                            TimeValue timeout)

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