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,org.elasticsearch.core.Releasable
-
Field Summary
Fields inherited from class org.elasticsearch.cluster.service.MasterService
MASTER_SERVICE_SLOW_TASK_LOGGING_THRESHOLD_SETTING, MASTER_SERVICE_STARVATION_LOGGING_THRESHOLD_SETTING, MASTER_UPDATE_THREAD_NAME, STATE_UPDATE_ACTION_NAME, threadPoolFields inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent
lifecycle -
Constructor Summary
ConstructorsConstructorDescriptionFakeThreadPoolMasterService(String nodeName, ThreadPool threadPool, Consumer<Runnable> taskExecutor) -
Method Summary
Modifier and TypeMethodDescriptionprotected ExecutorServiceincrementVersion(ClusterState clusterState) protected voidpublish(ClusterStatePublicationEvent clusterStatePublicationEvent, ClusterStatePublisher.AckListener ackListener, ActionListener<Void> publicationListener) protected ClusterStatePublisher.AckListenerwrapAckListener(ClusterStatePublisher.AckListener ackListener) Methods inherited from class org.elasticsearch.cluster.service.MasterService
assertMasterUpdateOrTestThread, assertNotMasterUpdateThread, createTaskQueue, doClose, doStart, doStop, getClusterStateUpdateStats, getMaxTaskWaitTime, isMasterUpdateThread, isPublishFailureException, numberOfPendingTasks, pendingTasks, publicationMayFail, setClusterStatePublisher, setClusterStateSupplier, submitUnbatchedStateUpdateTaskMethods inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent
addLifecycleListener, close, lifecycleState, start, stop
-
Constructor Details
-
FakeThreadPoolMasterService
public FakeThreadPoolMasterService(String nodeName, ThreadPool threadPool, Consumer<Runnable> taskExecutor)
-
-
Method Details
-
createThreadPoolExecutor
- Overrides:
createThreadPoolExecutorin classMasterService
-
incrementVersion
- Overrides:
incrementVersionin classMasterService
-
publish
protected void publish(ClusterStatePublicationEvent clusterStatePublicationEvent, ClusterStatePublisher.AckListener ackListener, ActionListener<Void> publicationListener) - Overrides:
publishin classMasterService
-
wrapAckListener
protected ClusterStatePublisher.AckListener wrapAckListener(ClusterStatePublisher.AckListener ackListener)
-