Package org.elasticsearch.cluster.service

Class FakeThreadPoolMasterService

java.lang.Object

org.elasticsearch.common.component.AbstractLifecycleComponent

org.elasticsearch.cluster.service.MasterService

org.elasticsearch.cluster.service.FakeThreadPoolMasterService

All Implemented Interfaces:

Closeable, AutoCloseable, LifecycleComponent, Releasable

public class FakeThreadPoolMasterService
extends MasterService

Field Summary

Fields inherited from class org.elasticsearch.cluster.service.MasterService

MASTER_SERVICE_EXECUTION_HISTORY_SIZE_SETTING, MASTER_SERVICE_SLOW_TASK_LOGGING_THRESHOLD_SETTING, MASTER_SERVICE_STARVATION_LOGGING_THRESHOLD_SETTING, MASTER_UPDATE_THREAD_NAME, STATE_UPDATE_ACTION_NAME, threadPool

Fields inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

lifecycle

Constructor Summary

Constructors

Constructor	Description
FakeThreadPoolMasterService(String nodeName, ThreadPool threadPool, Consumer<Runnable> taskExecutor)

Method Summary

Modifier and Type	Method	Description
protected ExecutorService	createThreadPoolExecutor()
ClusterState.Builder	incrementVersion(ClusterState clusterState)
protected void	publish(ClusterStatePublicationEvent clusterStatePublicationEvent, ClusterStatePublisher.AckListener ackListener, ActionListener<Void> publicationListener)
protected ClusterStatePublisher.AckListener	wrapAckListener(ClusterStatePublisher.AckListener ackListener)

Methods inherited from class org.elasticsearch.cluster.service.MasterService

assertMasterUpdateOrTestThread, assertNotMasterUpdateThread, createTaskQueue, doClose, doStart, doStop, getClusterStateUpdateStats, getMaxTaskWaitTime, isInfiniteTaskTimeout, isMasterUpdateThread, isPublishFailureException, maybeLimitMasterNodeTimeout, numberOfPendingTasks, pendingTasks, publicationMayFail, setClusterStatePublisher, setClusterStateSupplier, submitUnbatchedStateUpdateTask

Methods inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

addLifecycleListener, close, lifecycleState, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

FakeThreadPoolMasterService

public FakeThreadPoolMasterService(String nodeName,
 ThreadPool threadPool,
 Consumer<Runnable> taskExecutor)

Method Details

createThreadPoolExecutor

protected ExecutorService createThreadPoolExecutor()

Overrides:

createThreadPoolExecutor in class MasterService

incrementVersion

public ClusterState.Builder incrementVersion(ClusterState clusterState)

Overrides:

incrementVersion in class MasterService

publish

protected void publish(ClusterStatePublicationEvent clusterStatePublicationEvent,
 ClusterStatePublisher.AckListener ackListener,
 ActionListener<Void> publicationListener)

Overrides:

publish in class MasterService

wrapAckListener

protected ClusterStatePublisher.AckListener wrapAckListener(ClusterStatePublisher.AckListener ackListener)