org.elasticsearch.cluster.service

Class InternalClusterService

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

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

org.elasticsearch.cluster.service.InternalClusterService

All Implemented Interfaces:

AutoCloseable, ClusterService, LifecycleComponent<ClusterService>, Releasable

public class InternalClusterService
extends AbstractLifecycleComponent<ClusterService>
implements ClusterService

Field Summary

Fields

Modifier and Type	Field and Description
static String	SETTING_CLUSTER_SERVICE_RECONNECT_INTERVAL
static String	SETTING_CLUSTER_SERVICE_SLOW_TASK_LOGGING_THRESHOLD
static String	UPDATE_THREAD_NAME

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
InternalClusterService(Settings settings, DiscoveryService discoveryService, OperationRouting operationRouting, TransportService transportService, NodeSettingsService nodeSettingsService, ThreadPool threadPool, ClusterName clusterName, DiscoveryNodeService discoveryNodeService, Version version)

Method Summary

Modifier and Type	Method and Description
void	add(ClusterStateListener listener) Adds a listener for updated cluster states.
void	add(LocalNodeMasterListener listener) Add a listener for on/off local node master events
void	add(TimeValue timeout, TimeoutClusterStateListener listener) Adds a cluster state listener that will timeout after the provided timeout, and is executed after the clusterstate has been successfully applied ie.
void	addFirst(ClusterStateListener listener) Adds a priority listener for updated cluster states.
void	addInitialStateBlock(ClusterBlock block) Adds an initial block to be set on the first cluster state created.
void	addLast(ClusterStateListener listener) Adds last listener.
protected void	doClose()
protected void	doStart()
protected void	doStop()
DiscoveryNode	localNode() The local node.
int	numberOfPendingTasks() Returns the number of currently pending tasks.
OperationRouting	operationRouting() The operation routing.
List<PendingClusterTask>	pendingTasks() Returns the tasks that are pending.
void	remove(ClusterStateListener listener) Removes a listener for updated cluster states.
void	remove(LocalNodeMasterListener listener) Remove the given listener for on/off local master events
void	removeInitialStateBlock(ClusterBlock block) Remove an initial block to be set on the first cluster state created.
NodeSettingsService	settingsService()
ClusterState	state() The current state.
void	submitStateUpdateTask(String source, ClusterStateUpdateTask updateTask) Submits a task that will update the cluster state (the task has a default priority of Priority.NORMAL).
void	submitStateUpdateTask(String source, Priority priority, ClusterStateUpdateTask updateTask) Submits a task that will update the cluster state.

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_CLUSTER_SERVICE_SLOW_TASK_LOGGING_THRESHOLD

public static final String SETTING_CLUSTER_SERVICE_SLOW_TASK_LOGGING_THRESHOLD

See Also:

Constant Field Values

SETTING_CLUSTER_SERVICE_RECONNECT_INTERVAL

public static final String SETTING_CLUSTER_SERVICE_RECONNECT_INTERVAL

See Also:

Constant Field Values

UPDATE_THREAD_NAME

public static final String UPDATE_THREAD_NAME

See Also:

Constant Field Values

Constructor Detail

InternalClusterService

@Inject
public InternalClusterService(Settings settings,
                                      DiscoveryService discoveryService,
                                      OperationRouting operationRouting,
                                      TransportService transportService,
                                      NodeSettingsService nodeSettingsService,
                                      ThreadPool threadPool,
                                      ClusterName clusterName,
                                      DiscoveryNodeService discoveryNodeService,
                                      Version version)

Method Detail

settingsService

public NodeSettingsService settingsService()

addInitialStateBlock

public void addInitialStateBlock(ClusterBlock block)
                          throws ElasticsearchIllegalStateException

Description copied from interface: ClusterService

Adds an initial block to be set on the first cluster state created.

Specified by:

addInitialStateBlock in interface ClusterService

Throws:

ElasticsearchIllegalStateException

removeInitialStateBlock

public void removeInitialStateBlock(ClusterBlock block)
                             throws ElasticsearchIllegalStateException

Description copied from interface: ClusterService

Remove an initial block to be set on the first cluster state created.

Specified by:

removeInitialStateBlock in interface ClusterService

Throws:

ElasticsearchIllegalStateException

doStart

protected void doStart()
                throws ElasticsearchException

Specified by:

doStart in class AbstractLifecycleComponent<ClusterService>

Throws:

ElasticsearchException

doStop

protected void doStop()
               throws ElasticsearchException

Specified by:

doStop in class AbstractLifecycleComponent<ClusterService>

Throws:

ElasticsearchException

doClose

protected void doClose()
                throws ElasticsearchException

Specified by:

doClose in class AbstractLifecycleComponent<ClusterService>

Throws:

ElasticsearchException

localNode

public DiscoveryNode localNode()

Description copied from interface: ClusterService

The local node.

Specified by:

localNode in interface ClusterService

operationRouting

public OperationRouting operationRouting()

Description copied from interface: ClusterService

The operation routing.

Specified by:

operationRouting in interface ClusterService

state

public ClusterState state()

Description copied from interface: ClusterService

The current state.

Specified by:

state in interface ClusterService

addFirst

public void addFirst(ClusterStateListener listener)

Description copied from interface: ClusterService

Adds a priority listener for updated cluster states.

Specified by:

addFirst in interface ClusterService

addLast

public void addLast(ClusterStateListener listener)

Description copied from interface: ClusterService

Adds last listener.

Specified by:

addLast in interface ClusterService

add

public void add(ClusterStateListener listener)

Description copied from interface: ClusterService

Adds a listener for updated cluster states.

Specified by:

add in interface ClusterService

remove

public void remove(ClusterStateListener listener)

Description copied from interface: ClusterService

Removes a listener for updated cluster states.

Specified by:

remove in interface ClusterService

add

public void add(LocalNodeMasterListener listener)

Description copied from interface: ClusterService

Add a listener for on/off local node master events

Specified by:

add in interface ClusterService

remove

public void remove(LocalNodeMasterListener listener)

Description copied from interface: ClusterService

Remove the given listener for on/off local master events

Specified by:

remove in interface ClusterService

add

public void add(TimeValue timeout,
                TimeoutClusterStateListener listener)

Description copied from interface: ClusterService

Adds a cluster state listener that will timeout after the provided timeout, and is executed after the clusterstate has been successfully applied ie. is in state ClusterState.ClusterStateStatus.APPLIED

Specified by:

add in interface ClusterService

submitStateUpdateTask

public void submitStateUpdateTask(String source,
                                  ClusterStateUpdateTask updateTask)

Description copied from interface: ClusterService

Submits a task that will update the cluster state (the task has a default priority of Priority.NORMAL).

Specified by:

submitStateUpdateTask in interface ClusterService

submitStateUpdateTask

public void submitStateUpdateTask(String source,
                                  Priority priority,
                                  ClusterStateUpdateTask updateTask)

Description copied from interface: ClusterService

Submits a task that will update the cluster state.

Specified by:

submitStateUpdateTask in interface ClusterService

pendingTasks

public List<PendingClusterTask> pendingTasks()

Description copied from interface: ClusterService

Returns the tasks that are pending.

Specified by:

pendingTasks in interface ClusterService

numberOfPendingTasks

public int numberOfPendingTasks()

Description copied from interface: ClusterService

Returns the number of currently pending tasks.

Specified by:

numberOfPendingTasks in interface ClusterService