org.elasticsearch.discovery

Interface Discovery

All Superinterfaces:

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

All Known Implementing Classes:

LocalDiscovery, NoneDiscovery, SingleNodeDiscovery, ZenDiscovery

public interface Discovery
extends LifecycleComponent

A pluggable module allowing to implement discovery of other nodes, publishing of the cluster state to all nodes, electing a master of the cluster that raises cluster state change events.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	Discovery.AckListener
static class	Discovery.FailedToCommitClusterStateException

Method Summary

Modifier and Type	Method and Description
DiscoverySettings	getDiscoverySettings()
int	getMinimumMasterNodes()
DiscoveryNode	localNode()
java.lang.String	nodeDescription()
void	publish(ClusterChangedEvent clusterChangedEvent, Discovery.AckListener ackListener) 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 interface org.elasticsearch.common.component.LifecycleComponent

addLifecycleListener, lifecycleState, removeLifecycleListener, start, stop

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

close

Method Detail

localNode

DiscoveryNode localNode()

nodeDescription

java.lang.String nodeDescription()

setAllocationService

void setAllocationService(AllocationService allocationService)

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

publish

void publish(ClusterChangedEvent clusterChangedEvent,
             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 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.

stats

DiscoveryStats stats()

Returns:

stats about the discovery

getDiscoverySettings

DiscoverySettings getDiscoverySettings()

startInitialJoin

void startInitialJoin()

Triggers the first join cycle

getMinimumMasterNodes

int getMinimumMasterNodes()

Returns:

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