org.elasticsearch.discovery.zen

Class ZenDiscovery

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

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

org.elasticsearch.discovery.zen.ZenDiscovery

All Implemented Interfaces:

AutoCloseable, LifecycleComponent<Discovery>, Releasable, Discovery, DiscoveryNodesProvider, PingContextProvider

public class ZenDiscovery
extends AbstractLifecycleComponent<Discovery>
implements Discovery, PingContextProvider

Nested Class Summary

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

Discovery.AckListener

Field Summary

Fields

Modifier and Type	Field and Description
static String	DISCOVERY_REJOIN_ACTION_NAME
static String	SETTING_JOIN_RETRY_ATTEMPTS
static String	SETTING_JOIN_RETRY_DELAY
static String	SETTING_JOIN_TIMEOUT
static String	SETTING_MASTER_ELECTION_FILTER_CLIENT
static String	SETTING_MASTER_ELECTION_FILTER_DATA
static String	SETTING_MAX_PINGS_FROM_ANOTHER_MASTER
static String	SETTING_PING_TIMEOUT
static String	SETTING_REJOIN_ON_MASTER_GONE
static String	SETTING_SEND_LEAVE_REQUEST

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
ZenDiscovery(Settings settings, ClusterName clusterName, ThreadPool threadPool, TransportService transportService, ClusterService clusterService, NodeSettingsService nodeSettingsService, DiscoveryNodeService discoveryNodeService, ZenPingService pingService, ElectMasterService electMasterService, DiscoverySettings discoverySettings, DynamicSettings dynamicSettings)

Method Summary

Modifier and Type	Method and Description
void	addListener(InitialStateDiscoveryListener listener)
protected void	doClose()
protected void	doStart()
protected void	doStop()
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()
String	nodeDescription()
boolean	nodeHasJoinedClusterOnce() return true if this node has previously joined the cluster at least once.
DiscoveryNodes	nodes() start of PingContextProvider implementation
NodeService	nodeService()
void	publish(ClusterState clusterState, Discovery.AckListener ackListener) end of PingContextProvider implementation
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

Field Detail

SETTING_REJOIN_ON_MASTER_GONE

public static final String SETTING_REJOIN_ON_MASTER_GONE

See Also:

Constant Field Values

SETTING_PING_TIMEOUT

public static final String SETTING_PING_TIMEOUT

See Also:

Constant Field Values

SETTING_JOIN_TIMEOUT

public static final String SETTING_JOIN_TIMEOUT

See Also:

Constant Field Values

SETTING_JOIN_RETRY_ATTEMPTS

public static final String SETTING_JOIN_RETRY_ATTEMPTS

See Also:

Constant Field Values

SETTING_JOIN_RETRY_DELAY

public static final String SETTING_JOIN_RETRY_DELAY

See Also:

Constant Field Values

SETTING_MAX_PINGS_FROM_ANOTHER_MASTER

public static final String SETTING_MAX_PINGS_FROM_ANOTHER_MASTER

See Also:

Constant Field Values

SETTING_SEND_LEAVE_REQUEST

public static final String SETTING_SEND_LEAVE_REQUEST

See Also:

Constant Field Values

SETTING_MASTER_ELECTION_FILTER_CLIENT

public static final String SETTING_MASTER_ELECTION_FILTER_CLIENT

See Also:

Constant Field Values

SETTING_MASTER_ELECTION_FILTER_DATA

public static final String SETTING_MASTER_ELECTION_FILTER_DATA

See Also:

Constant Field Values

DISCOVERY_REJOIN_ACTION_NAME

public static final String DISCOVERY_REJOIN_ACTION_NAME

See Also:

Constant Field Values

Constructor Detail

ZenDiscovery

@Inject
public ZenDiscovery(Settings settings,
                            ClusterName clusterName,
                            ThreadPool threadPool,
                            TransportService transportService,
                            ClusterService clusterService,
                            NodeSettingsService nodeSettingsService,
                            DiscoveryNodeService discoveryNodeService,
                            ZenPingService pingService,
                            ElectMasterService electMasterService,
                            DiscoverySettings discoverySettings,
                            @ClusterDynamicSettings
                            DynamicSettings dynamicSettings)

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

nodes

public DiscoveryNodes nodes()

start of PingContextProvider implementation

Specified by:

nodes in interface DiscoveryNodesProvider

nodeService

public NodeService nodeService()

Specified by:

nodeService in interface DiscoveryNodesProvider

nodeHasJoinedClusterOnce

public boolean nodeHasJoinedClusterOnce()

Description copied from interface: PingContextProvider

return true if this node has previously joined the cluster at least once. False if this is first join

Specified by:

nodeHasJoinedClusterOnce in interface PingContextProvider

publish

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

end of PingContextProvider implementation

Specified by:

publish in interface Discovery

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.