public class MembershipAction extends AbstractComponent
Modifier and Type | Class and Description |
---|---|
static interface |
MembershipAction.JoinCallback |
static interface |
MembershipAction.MembershipListener |
Modifier and Type | Field and Description |
---|---|
static String |
DISCOVERY_JOIN_ACTION_NAME |
static String |
DISCOVERY_JOIN_VALIDATE_ACTION_NAME |
static String |
DISCOVERY_LEAVE_ACTION_NAME |
componentSettings, logger, settings
Constructor and Description |
---|
MembershipAction(Settings settings,
ClusterService clusterService,
TransportService transportService,
DiscoveryNodesProvider nodesProvider,
MembershipAction.MembershipListener listener) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
sendJoinRequest(DiscoveryNode masterNode,
DiscoveryNode node) |
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,
TimeValue timeout)
Validates the join request, throwing a failure if it failed.
|
nodeName
public static final String DISCOVERY_JOIN_ACTION_NAME
public static final String DISCOVERY_JOIN_VALIDATE_ACTION_NAME
public static final String DISCOVERY_LEAVE_ACTION_NAME
public MembershipAction(Settings settings, ClusterService clusterService, TransportService transportService, DiscoveryNodesProvider nodesProvider, MembershipAction.MembershipListener listener)
public void close()
public void sendLeaveRequest(DiscoveryNode masterNode, DiscoveryNode node)
public void sendLeaveRequestBlocking(DiscoveryNode masterNode, DiscoveryNode node, TimeValue timeout) throws ElasticsearchException
ElasticsearchException
public void sendJoinRequest(DiscoveryNode masterNode, DiscoveryNode node)
public void sendJoinRequestBlocking(DiscoveryNode masterNode, DiscoveryNode node, TimeValue timeout) throws ElasticsearchException
ElasticsearchException
public void sendValidateJoinRequestBlocking(DiscoveryNode node, TimeValue timeout) throws ElasticsearchException
ElasticsearchException
Copyright © 2009–2015. All rights reserved.