org.elasticsearch.discovery.local

Class LocalDiscovery

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

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

org.elasticsearch.discovery.local.LocalDiscovery

All Implemented Interfaces:

AutoCloseable, LifecycleComponent<Discovery>, Releasable, Discovery

public class LocalDiscovery
extends AbstractLifecycleComponent<Discovery>
implements Discovery

Nested Class Summary

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

Discovery.AckListener

Field Summary

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
LocalDiscovery(Settings settings, ClusterName clusterName, TransportService transportService, ClusterService clusterService, DiscoveryNodeService discoveryNodeService, Version version, DiscoverySettings discoverySettings)

Method Summary

Modifier and Type	Method and Description
void	addListener(InitialStateDiscoveryListener listener)
protected void	doClose()
protected void	doStart()
protected void	doStop()
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	removeListener(InitialStateDiscoveryListener listener)
void	setNodeService(NodeService nodeService) Here as a hack to solve dep injection problem...
void	setRoutingService(RoutingService routingService) Another hack to solve dep injection problem..., note, this will be called before any start is called.

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

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

addLifecycleListener, lifecycleState, removeLifecycleListener, start, stop

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

close

Constructor Detail

LocalDiscovery

@Inject
public LocalDiscovery(Settings settings,
                              ClusterName clusterName,
                              TransportService transportService,
                              ClusterService clusterService,
                              DiscoveryNodeService discoveryNodeService,
                              Version version,
                              DiscoverySettings discoverySettings)

Method Detail

setNodeService

public void setNodeService(@Nullable
                           NodeService nodeService)

Description copied from interface: Discovery

Here as a hack to solve dep injection problem...

Specified by:

setNodeService in interface Discovery

setRoutingService

public void setRoutingService(RoutingService routingService)

Description copied from interface: Discovery

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

Specified by:

setRoutingService in interface Discovery

doStart

protected void doStart()
                throws ElasticsearchException

Specified by:

doStart in class AbstractLifecycleComponent<Discovery>

Throws:

ElasticsearchException

doStop

protected void doStop()
               throws ElasticsearchException

Specified by:

doStop in class AbstractLifecycleComponent<Discovery>

Throws:

ElasticsearchException

doClose

protected void doClose()
                throws ElasticsearchException

Specified by:

doClose in class AbstractLifecycleComponent<Discovery>

Throws:

ElasticsearchException

localNode

public DiscoveryNode localNode()

Specified by:

localNode in interface Discovery

addListener

public void addListener(InitialStateDiscoveryListener listener)

Specified by:

addListener in interface Discovery

removeListener

public void removeListener(InitialStateDiscoveryListener listener)

Specified by:

removeListener in interface Discovery

nodeDescription

public String nodeDescription()

Specified by:

nodeDescription in interface Discovery

publish

public void publish(ClusterState clusterState,
                    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.

Specified by:

publish in interface Discovery