org.elasticsearch.discovery.zen.membership
Class MembershipAction

java.lang.Object
  org.elasticsearch.common.component.AbstractComponent
      org.elasticsearch.discovery.zen.membership.MembershipAction

public class MembershipAction
extends AbstractComponent

Nested Class Summary

static interface

MembershipAction.MembershipListener

Field Summary

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

componentSettings, logger, settings

Constructor Summary

MembershipAction(Settings settings, TransportService transportService, DiscoveryNodesProvider nodesProvider, MembershipAction.MembershipListener listener)

Method Summary

void	close()
void	sendJoinRequest(DiscoveryNode masterNode, DiscoveryNode node)
ClusterState	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 clusterState, 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

Constructor Detail

MembershipAction

public MembershipAction(Settings settings,
                        TransportService transportService,
                        DiscoveryNodesProvider nodesProvider,
                        MembershipAction.MembershipListener listener)

Method Detail

close

public void close()

sendLeaveRequest

public void sendLeaveRequest(DiscoveryNode masterNode,
                             DiscoveryNode node)

sendLeaveRequestBlocking

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

Throws:

ElasticSearchException

sendJoinRequest

public void sendJoinRequest(DiscoveryNode masterNode,
                            DiscoveryNode node)

sendJoinRequestBlocking

public ClusterState sendJoinRequestBlocking(DiscoveryNode masterNode,
                                            DiscoveryNode node,
                                            TimeValue timeout)
                                     throws ElasticSearchException

Throws:

ElasticSearchException

sendValidateJoinRequestBlocking

public void sendValidateJoinRequestBlocking(DiscoveryNode node,
                                            ClusterState clusterState,
                                            TimeValue timeout)
                                     throws ElasticSearchException

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

Throws:

ElasticSearchException