org.elasticsearch.discovery.zen

Class ZenDiscovery

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.common.component.AbstractLifecycleComponent

org.elasticsearch.discovery.zen.ZenDiscovery

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, LifecycleComponent, Releasable, Discovery, PingContextProvider

public class ZenDiscovery
extends AbstractLifecycleComponent
implements Discovery, PingContextProvider

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ZenDiscovery.RejoinClusterRequest

Nested classes/interfaces inherited from interface org.elasticsearch.discovery.Discovery

Discovery.AckListener, Discovery.FailedToCommitClusterStateException

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DISCOVERY_REJOIN_ACTION_NAME
static Setting<java.lang.Integer>	JOIN_RETRY_ATTEMPTS_SETTING
static Setting<TimeValue>	JOIN_RETRY_DELAY_SETTING
static Setting<TimeValue>	JOIN_TIMEOUT_SETTING
static Setting<java.lang.Boolean>	MASTER_ELECTION_IGNORE_NON_MASTER_PINGS_SETTING
static Setting<TimeValue>	MASTER_ELECTION_WAIT_FOR_JOINS_TIMEOUT_SETTING
static Setting<java.lang.Integer>	MAX_PINGS_FROM_ANOTHER_MASTER_SETTING
static Setting<TimeValue>	PING_TIMEOUT_SETTING
static Setting<java.lang.Boolean>	SEND_LEAVE_REQUEST_SETTING
protected ZenPing	zenPing

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

lifecycle

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

deprecationLogger, logger, settings

Constructor Summary

Constructors

Constructor and Description
ZenDiscovery(Settings settings, ThreadPool threadPool, TransportService transportService, NamedWriteableRegistry namedWriteableRegistry, ClusterService clusterService, UnicastHostsProvider hostsProvider)

Method Summary

Modifier and Type	Method and Description
ClusterState	clusterState() return the current cluster state of the node
protected void	doClose()
protected void	doStart()
protected void	doStop()
DiscoverySettings	getDiscoverySettings()
java.util.Set<DiscoveryNode>	getFaultDetectionNodes() Gets the current set of nodes involved in the node fault detection.
int	getMinimumMasterNodes()
boolean	joiningCluster() returns true if zen discovery is started and there is a currently a background thread active for (re)joining the cluster used for testing.
DiscoveryNode	localNode()
protected ZenPing	newZenPing(Settings settings, ThreadPool threadPool, TransportService transportService, UnicastHostsProvider hostsProvider)
java.lang.String	nodeDescription()
ClusterState[]	pendingClusterStates()
void	publish(ClusterChangedEvent clusterChangedEvent, Discovery.AckListener ackListener) Publish all the changes to the cluster from the master (can be called just by the master).
protected ClusterStateTaskExecutor.ClusterTasksResult<LocalClusterUpdateTask>	rejoin(ClusterState clusterState, java.lang.String reason)
void	setAllocationService(AllocationService allocationService) Another hack to solve dep injection problem..., note, this will be called before any start is called.
static boolean	shouldIgnoreOrRejectNewClusterState(org.apache.logging.log4j.Logger logger, ClusterState currentState, ClusterState newClusterState) In the case we follow an elected master the new cluster state needs to have the same elected master and the new cluster state version needs to be equal or higher than our cluster state version.
void	startInitialJoin() Triggers the first join cycle
DiscoveryStats	stats()
static void	validateStateIsFromCurrentMaster(org.apache.logging.log4j.Logger logger, DiscoveryNodes currentNodes, ClusterState newClusterState) In the case we follow an elected master the new cluster state needs to have the same elected master This method checks for this and throws an exception if needed

Methods inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop

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

logDeprecatedSetting, logRemovedSetting, nodeName

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.common.component.LifecycleComponent

addLifecycleListener, lifecycleState, removeLifecycleListener, start, stop

Methods inherited from interface org.elasticsearch.common.lease.Releasable

close

Field Detail

PING_TIMEOUT_SETTING

public static final Setting<TimeValue> PING_TIMEOUT_SETTING

JOIN_TIMEOUT_SETTING

public static final Setting<TimeValue> JOIN_TIMEOUT_SETTING

JOIN_RETRY_ATTEMPTS_SETTING

public static final Setting<java.lang.Integer> JOIN_RETRY_ATTEMPTS_SETTING

JOIN_RETRY_DELAY_SETTING

public static final Setting<TimeValue> JOIN_RETRY_DELAY_SETTING

MAX_PINGS_FROM_ANOTHER_MASTER_SETTING

public static final Setting<java.lang.Integer> MAX_PINGS_FROM_ANOTHER_MASTER_SETTING

SEND_LEAVE_REQUEST_SETTING

public static final Setting<java.lang.Boolean> SEND_LEAVE_REQUEST_SETTING

MASTER_ELECTION_WAIT_FOR_JOINS_TIMEOUT_SETTING

public static final Setting<TimeValue> MASTER_ELECTION_WAIT_FOR_JOINS_TIMEOUT_SETTING

MASTER_ELECTION_IGNORE_NON_MASTER_PINGS_SETTING

public static final Setting<java.lang.Boolean> MASTER_ELECTION_IGNORE_NON_MASTER_PINGS_SETTING

DISCOVERY_REJOIN_ACTION_NAME

public static final java.lang.String DISCOVERY_REJOIN_ACTION_NAME

See Also:

Constant Field Values

zenPing

protected final ZenPing zenPing

Constructor Detail

ZenDiscovery

public ZenDiscovery(Settings settings,
                    ThreadPool threadPool,
                    TransportService transportService,
                    NamedWriteableRegistry namedWriteableRegistry,
                    ClusterService clusterService,
                    UnicastHostsProvider hostsProvider)

Method Detail

newZenPing

protected ZenPing newZenPing(Settings settings,
                             ThreadPool threadPool,
                             TransportService transportService,
                             UnicastHostsProvider hostsProvider)

setAllocationService

public void setAllocationService(AllocationService allocationService)

Description copied from interface: Discovery

Another hack to solve dep injection problem..., note, this will be called before any start is called.

Specified by:

setAllocationService in interface Discovery

doStart

protected void doStart()

Specified by:

doStart in class AbstractLifecycleComponent

startInitialJoin

public void startInitialJoin()

Description copied from interface: Discovery

Triggers the first join cycle

Specified by:

startInitialJoin in interface Discovery

doStop

protected void doStop()

Specified by:

doStop in class AbstractLifecycleComponent

doClose

protected void doClose()
                throws java.io.IOException

Specified by:

doClose in class AbstractLifecycleComponent

Throws:

java.io.IOException

localNode

public DiscoveryNode localNode()

Specified by:

localNode in interface Discovery

nodeDescription

public java.lang.String nodeDescription()

Specified by:

nodeDescription in interface Discovery

clusterState

public ClusterState clusterState()

Description copied from interface: PingContextProvider

return the current cluster state of the node

Specified by:

clusterState in interface PingContextProvider

publish

public void publish(ClusterChangedEvent clusterChangedEvent,
                    Discovery.AckListener ackListener)

Description copied from interface: Discovery

Publish all the changes to the cluster from the master (can be called just by the master). The publish process should not publish this state to the master as well! (the master is sending it...). The Discovery.AckListener allows to keep track of the ack received from nodes, and verify whether they updated their own cluster state or not. The method is guaranteed to throw a Discovery.FailedToCommitClusterStateException if the change is not committed and should be rejected. Any other exception signals the something wrong happened but the change is committed.

Specified by:

publish in interface Discovery

getFaultDetectionNodes

public java.util.Set<DiscoveryNode> getFaultDetectionNodes()

Gets the current set of nodes involved in the node fault detection. NB: for testing purposes

stats

public DiscoveryStats stats()

Specified by:

stats in interface Discovery

Returns:

stats about the discovery

getDiscoverySettings

public DiscoverySettings getDiscoverySettings()

Specified by:

getDiscoverySettings in interface Discovery

getMinimumMasterNodes

public int getMinimumMasterNodes()

Specified by:

getMinimumMasterNodes in interface Discovery

Returns:

the current value of minimum master nodes, or -1 for not set

joiningCluster

public boolean joiningCluster()

returns true if zen discovery is started and there is a currently a background thread active for (re)joining the cluster used for testing.

pendingClusterStates

public ClusterState[] pendingClusterStates()

shouldIgnoreOrRejectNewClusterState

public static boolean shouldIgnoreOrRejectNewClusterState(org.apache.logging.log4j.Logger logger,
                                                          ClusterState currentState,
                                                          ClusterState newClusterState)

In the case we follow an elected master the new cluster state needs to have the same elected master and the new cluster state version needs to be equal or higher than our cluster state version. If the first condition fails we reject the cluster state and throw an error. If the second condition fails we ignore the cluster state.

validateStateIsFromCurrentMaster

public static void validateStateIsFromCurrentMaster(org.apache.logging.log4j.Logger logger,
                                                    DiscoveryNodes currentNodes,
                                                    ClusterState newClusterState)

In the case we follow an elected master the new cluster state needs to have the same elected master This method checks for this and throws an exception if needed

rejoin

protected ClusterStateTaskExecutor.ClusterTasksResult<LocalClusterUpdateTask> rejoin(ClusterState clusterState,
                                                                                     java.lang.String reason)