org.elasticsearch.discovery

Class DiscoveryService

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.common.component.AbstractLifecycleComponent<DiscoveryService>

org.elasticsearch.discovery.DiscoveryService

All Implemented Interfaces:

AutoCloseable, LifecycleComponent<DiscoveryService>, Releasable

public class DiscoveryService
extends AbstractLifecycleComponent<DiscoveryService>

Field Summary

Fields

Modifier and Type	Field and Description
static String	SETTING_INITIAL_STATE_TIMEOUT

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

lifecycle

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

componentSettings, logger, settings

Constructor Summary

Constructors

Constructor and Description
DiscoveryService(Settings settings, DiscoverySettings discoverySettings, Discovery discovery)

Method Summary

Modifier and Type	Method and Description
protected void	doClose()
protected void	doStart()
protected void	doStop()
static String	generateNodeId(Settings settings)
ClusterBlock	getNoMasterBlock()
boolean	initialStateReceived() Returns true if the initial state was received within the timeout waiting for it on doStart().
DiscoveryNode	localNode()
String	nodeDescription()
void	publish(ClusterState clusterState, Discovery.AckListener ackListener) Publish all the changes to the cluster from the master (can be called just by the master).
void	waitForInitialState()

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

addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop

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

SETTING_INITIAL_STATE_TIMEOUT

public static final String SETTING_INITIAL_STATE_TIMEOUT

See Also:

Constant Field Values

Constructor Detail

DiscoveryService

@Inject
public DiscoveryService(Settings settings,
                                DiscoverySettings discoverySettings,
                                Discovery discovery)

Method Detail

getNoMasterBlock

public ClusterBlock getNoMasterBlock()

doStart

protected void doStart()
                throws ElasticsearchException

Specified by:

doStart in class AbstractLifecycleComponent<DiscoveryService>

Throws:

ElasticsearchException

waitForInitialState

public void waitForInitialState()

doStop

protected void doStop()
               throws ElasticsearchException

Specified by:

doStop in class AbstractLifecycleComponent<DiscoveryService>

Throws:

ElasticsearchException

doClose

protected void doClose()
                throws ElasticsearchException

Specified by:

doClose in class AbstractLifecycleComponent<DiscoveryService>

Throws:

ElasticsearchException

localNode

public DiscoveryNode localNode()

initialStateReceived

public boolean initialStateReceived()

Returns true if the initial state was received within the timeout waiting for it on doStart().

nodeDescription

public String nodeDescription()

publish

public void publish(ClusterState clusterState,
                    Discovery.AckListener ackListener)

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 acknowledge the publish event based on the response gotten from all nodes

generateNodeId

public static String generateNodeId(Settings settings)