File tree Expand file tree Collapse file tree 4 files changed +17
-2
lines changed
server/src/main/java/org/elasticsearch Expand file tree Collapse file tree 4 files changed +17
-2
lines changed Original file line number Diff line number Diff line change
1
+ pr : 112687
2
+ summary : Add `TaskManager` to `pluginServices`
3
+ area : Infra/Metrics
4
+ type : enhancement
5
+ issues : []
Original file line number Diff line number Diff line change @@ -855,7 +855,8 @@ private void construct(
855
855
featureService ,
856
856
systemIndices ,
857
857
dataStreamGlobalRetentionSettings ,
858
- documentParsingProvider
858
+ documentParsingProvider ,
859
+ taskManager
859
860
);
860
861
861
862
Collection <?> pluginComponents = pluginsService .flatMap (plugin -> {
Original file line number Diff line number Diff line change 24
24
import org .elasticsearch .plugins .internal .DocumentParsingProvider ;
25
25
import org .elasticsearch .repositories .RepositoriesService ;
26
26
import org .elasticsearch .script .ScriptService ;
27
+ import org .elasticsearch .tasks .TaskManager ;
27
28
import org .elasticsearch .telemetry .TelemetryProvider ;
28
29
import org .elasticsearch .threadpool .ThreadPool ;
29
30
import org .elasticsearch .watcher .ResourceWatcherService ;
@@ -48,5 +49,6 @@ public record PluginServiceInstances(
48
49
FeatureService featureService ,
49
50
SystemIndices systemIndices ,
50
51
DataStreamGlobalRetentionSettings dataStreamGlobalRetentionSettings ,
51
- DocumentParsingProvider documentParsingProvider
52
+ DocumentParsingProvider documentParsingProvider ,
53
+ TaskManager taskManager
52
54
) implements Plugin .PluginServices {}
Original file line number Diff line number Diff line change 31
31
import org .elasticsearch .plugins .internal .DocumentParsingProvider ;
32
32
import org .elasticsearch .repositories .RepositoriesService ;
33
33
import org .elasticsearch .script .ScriptService ;
34
+ import org .elasticsearch .tasks .TaskManager ;
34
35
import org .elasticsearch .telemetry .TelemetryProvider ;
35
36
import org .elasticsearch .threadpool .ExecutorBuilder ;
36
37
import org .elasticsearch .threadpool .ThreadPool ;
@@ -165,6 +166,12 @@ public interface PluginServices {
165
166
* A provider of utilities to observe and report parsing of documents
166
167
*/
167
168
DocumentParsingProvider documentParsingProvider ();
169
+
170
+ /**
171
+ * The task manager for the node. This should only be used by plugins
172
+ * to track task removal by registering a RemovedTaskListener.
173
+ */
174
+ TaskManager taskManager ();
168
175
}
169
176
170
177
/**
You can’t perform that action at this time.
0 commit comments