Package org.elasticsearch.test.tasks
Class MockTaskManager
java.lang.Object
org.elasticsearch.tasks.TaskManager
org.elasticsearch.test.tasks.MockTaskManager
- All Implemented Interfaces:
ClusterStateApplier
A mock task manager that allows adding listeners for events
-
Field Summary
FieldsModifier and TypeFieldDescription -
Constructor Summary
ConstructorsConstructorDescriptionMockTaskManager(Settings settings, ThreadPool threadPool, Set<String> taskHeaders) -
Method Summary
Modifier and TypeMethodDescriptionvoidaddListener(MockTaskManagerListener listener) register(String type, String action, TaskAwareRequest request) voidregisterRemovedTaskListener(RemovedTaskListener removedTaskListener) voidremoveListener(MockTaskManagerListener listener) unregister(Task task) Methods inherited from class org.elasticsearch.tasks.TaskManager
applyClusterState, assertCancellableTaskConsistency, cancel, cancelChildLocal, cancelChildRemote, cancelTaskAndDescendants, getBannedTaskIds, getCancellableTask, getCancellableTasks, getTask, getTaskHeaders, getTasks, register, registerAndExecute, registerChildConnection, removeBan, setBan, setTaskCancellationService, setTaskResultsService, startBanOnChildTasks, startTrackingCancellableChannelTask, storeResult, storeResult, unregisterRemovedTaskListener
-
Field Details
-
USE_MOCK_TASK_MANAGER_SETTING
-
SPY_TASK_MANAGER_SETTING
-
-
Constructor Details
-
MockTaskManager
-
-
Method Details
-
register
- Overrides:
registerin classTaskManager
-
unregister
- Overrides:
unregisterin classTaskManager
-
addListener
-
removeListener
-
registerRemovedTaskListener
- Overrides:
registerRemovedTaskListenerin classTaskManager
-