org.elasticsearch.discovery.single

Class SingleNodeDiscovery

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.common.component.AbstractLifecycleComponent

org.elasticsearch.discovery.single.SingleNodeDiscovery

All Implemented Interfaces:

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

public class SingleNodeDiscovery
extends AbstractLifecycleComponent
implements Discovery

A discovery implementation where the only member of the cluster is the local node.

Nested Class Summary

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

Discovery.AckListener, Discovery.FailedToCommitClusterStateException

Field Summary

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
SingleNodeDiscovery(Settings settings, ClusterService clusterService)

Method Summary

Modifier and Type	Method and Description
protected void	doClose()
protected void	doStart()
protected void	doStop()
DiscoverySettings	getDiscoverySettings()
int	getMinimumMasterNodes()
DiscoveryNode	localNode()
java.lang.String	nodeDescription()
void	publish(ClusterChangedEvent event, Discovery.AckListener listener) Publish all the changes to the cluster from the master (can be called just by the master).
void	setAllocationService(AllocationService allocationService) Another hack to solve dep injection problem..., note, this will be called before any start is called.
void	startInitialJoin() Triggers the first join cycle
DiscoveryStats	stats()

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

Constructor Detail

SingleNodeDiscovery

public SingleNodeDiscovery(Settings settings,
                           ClusterService clusterService)

Method Detail

localNode

public DiscoveryNode localNode()

Specified by:

localNode in interface Discovery

nodeDescription

public java.lang.String nodeDescription()

Specified by:

nodeDescription in interface Discovery

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

publish

public void publish(ClusterChangedEvent event,
                    Discovery.AckListener listener)

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

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

startInitialJoin

public void startInitialJoin()

Description copied from interface: Discovery

Triggers the first join cycle

Specified by:

startInitialJoin 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

doStart

protected void doStart()

Specified by:

doStart in class AbstractLifecycleComponent

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