Skip to content

Commit 47f0ec9

Browse files
committed
[Refactor] Task foundation classes to core library - pt 1 (opensearch-project#9082)
This is the first round refactor of the foundation Task classes from the server module to core and common library. This is split into separate commits due to control the surface area impacted by the change. This commit refactors the following classes: * o.o.action.ActionFuture -> :libs:opensearch-common * o.o.action.ActionListener -> :libs:opensearch-core * o.o.action.ActionResponse -> :libs:opensearch-core * o.o.action.NotifyOnceListener -> :libs:opensearch-core * o.o.common.compress.Compressor -> :libs:opensearch-core * o.o.node.ReportingService -> o.o.core.service in :libs:opensearch-core * o.o.tasks.TaskCancelledExceptoin -> :libs:opensearch-core * o.o.tasks.TaskId -> :libs:opensearch-core * o.o.common.xcontent.ObjectParserHelper -> :libs:opensearch-core The following task resource tracking classes are refactored into a new resourcetracker namespace under the o.o.core.tasks packed in :libs:opensearch-core * o.o.tasks.ResourceStats * o.o.tasks.ResourceStatsType * o.o.tasks.ResourceUsageMetric * o.o.tasks.TaskResourceStats * o.o.tasks.TaskResourceUsage * o.o.tasks.TaskThreadUsage * o.o.tasks.ThreadResourceInfo These refactors are part of the effort to split foundation classes into core libraries in support of modularity for serverless and cloud native implementations. Signed-off-by: Nicholas Walter Knize <nknize@apache.org> (cherry picked from commit de2b6b7)
1 parent d270315 commit 47f0ec9

File tree

873 files changed

+1229
-1152
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

873 files changed

+1229
-1152
lines changed

CHANGELOG.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -68,6 +68,7 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
6868
- Adds support for tracing runnable scenarios ([#8831](https://github.com/opensearch-project/OpenSearch/pull/8831))
6969
- Change shard_size and shard_min_doc_count evaluation to happen in shard level reduce phase ([#9085](https://github.com/opensearch-project/OpenSearch/pull/9085))
7070
- Add attributes to startSpan methods ([#9199](https://github.com/opensearch-project/OpenSearch/pull/9199))
71+
- [Refactor] Task foundation classes to core library - pt 1 ([#9082](https://github.com/opensearch-project/OpenSearch/pull/9082))
7172

7273
### Deprecated
7374

client/client-benchmark-noop-api-plugin/src/main/java/org/opensearch/plugin/noop/NoopPlugin.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@
3535
import org.opensearch.plugin.noop.action.bulk.RestNoopBulkAction;
3636
import org.opensearch.plugin.noop.action.bulk.TransportNoopBulkAction;
3737
import org.opensearch.action.ActionRequest;
38-
import org.opensearch.action.ActionResponse;
38+
import org.opensearch.core.action.ActionResponse;
3939
import org.opensearch.cluster.metadata.IndexNameExpressionResolver;
4040
import org.opensearch.cluster.node.DiscoveryNodes;
4141
import org.opensearch.common.settings.ClusterSettings;

client/client-benchmark-noop-api-plugin/src/main/java/org/opensearch/plugin/noop/action/bulk/TransportNoopBulkAction.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@
3131

3232
package org.opensearch.plugin.noop.action.bulk;
3333

34-
import org.opensearch.action.ActionListener;
34+
import org.opensearch.core.action.ActionListener;
3535
import org.opensearch.action.DocWriteRequest;
3636
import org.opensearch.action.DocWriteResponse;
3737
import org.opensearch.action.bulk.BulkItemResponse;

client/client-benchmark-noop-api-plugin/src/main/java/org/opensearch/plugin/noop/action/search/TransportNoopSearchAction.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@
3232
package org.opensearch.plugin.noop.action.search;
3333

3434
import org.apache.lucene.search.TotalHits;
35-
import org.opensearch.action.ActionListener;
35+
import org.opensearch.core.action.ActionListener;
3636
import org.opensearch.action.search.SearchRequest;
3737
import org.opensearch.action.search.SearchResponse;
3838
import org.opensearch.action.search.ShardSearchFailure;

client/rest-high-level/src/main/java/org/opensearch/client/ClusterClient.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@
3232

3333
package org.opensearch.client;
3434

35-
import org.opensearch.action.ActionListener;
35+
import org.opensearch.core.action.ActionListener;
3636
import org.opensearch.action.admin.cluster.health.ClusterHealthRequest;
3737
import org.opensearch.action.admin.cluster.health.ClusterHealthResponse;
3838
import org.opensearch.action.admin.cluster.settings.ClusterGetSettingsRequest;

client/rest-high-level/src/main/java/org/opensearch/client/IndicesClient.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@
3232

3333
package org.opensearch.client;
3434

35-
import org.opensearch.action.ActionListener;
35+
import org.opensearch.core.action.ActionListener;
3636
import org.opensearch.action.admin.indices.alias.IndicesAliasesRequest;
3737
import org.opensearch.action.admin.indices.alias.get.GetAliasesRequest;
3838
import org.opensearch.action.admin.indices.cache.clear.ClearIndicesCacheRequest;

client/rest-high-level/src/main/java/org/opensearch/client/IngestClient.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@
3232

3333
package org.opensearch.client;
3434

35-
import org.opensearch.action.ActionListener;
35+
import org.opensearch.core.action.ActionListener;
3636
import org.opensearch.action.ingest.DeletePipelineRequest;
3737
import org.opensearch.action.ingest.GetPipelineRequest;
3838
import org.opensearch.action.ingest.GetPipelineResponse;

client/rest-high-level/src/main/java/org/opensearch/client/RequestConverters.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1177,14 +1177,14 @@ Params withActions(List<String> actions) {
11771177
return this;
11781178
}
11791179

1180-
Params withTaskId(org.opensearch.tasks.TaskId taskId) {
1180+
Params withTaskId(org.opensearch.core.tasks.TaskId taskId) {
11811181
if (taskId != null && taskId.isSet()) {
11821182
return putParam("task_id", taskId.toString());
11831183
}
11841184
return this;
11851185
}
11861186

1187-
Params withParentTaskId(org.opensearch.tasks.TaskId parentTaskId) {
1187+
Params withParentTaskId(org.opensearch.core.tasks.TaskId parentTaskId) {
11881188
if (parentTaskId != null && parentTaskId.isSet()) {
11891189
return putParam("parent_task_id", parentTaskId.toString());
11901190
}

client/rest-high-level/src/main/java/org/opensearch/client/RestHighLevelClient.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@
3535
import org.apache.http.HttpEntity;
3636
import org.opensearch.OpenSearchException;
3737
import org.opensearch.OpenSearchStatusException;
38-
import org.opensearch.action.ActionListener;
38+
import org.opensearch.core.action.ActionListener;
3939
import org.opensearch.action.ActionRequest;
4040
import org.opensearch.action.ActionRequestValidationException;
4141
import org.opensearch.action.admin.cluster.node.tasks.list.ListTasksResponse;

client/rest-high-level/src/main/java/org/opensearch/client/RethrottleRequest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@
3232

3333
package org.opensearch.client;
3434

35-
import org.opensearch.tasks.TaskId;
35+
import org.opensearch.core.tasks.TaskId;
3636

3737
import java.util.Objects;
3838

0 commit comments

Comments
 (0)