Skip to content

feat(action): implement View, Ingestion, Scale and RemoteStore APIs #16

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
marevol merged 2 commits into from
Mar 21, 2026
Merged

feat(action): implement View, Ingestion, Scale and RemoteStore APIs #16

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
a31bc23
feat(action): implement View, Ingestion, Scale and RemoteStore APIs f…
marevol Mar 21, 2026
44a857d
fix: address Codex review findings for response parsing and test quality
marevol Mar 21, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
42 changes: 25 additions & 17 deletions src/main/java/org/codelibs/fesen/client/HttpAbstractClient.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -102,6 +102,7 @@
import org.opensearch.action.admin.cluster.node.usage.NodesUsageRequest;
import org.opensearch.action.admin.cluster.node.usage.NodesUsageRequestBuilder;
import org.opensearch.action.admin.cluster.node.usage.NodesUsageResponse;
import org.opensearch.action.admin.cluster.remotestore.metadata.RemoteStoreMetadataAction;
import org.opensearch.action.admin.cluster.remotestore.metadata.RemoteStoreMetadataRequestBuilder;
import org.opensearch.action.admin.cluster.remotestore.restore.RestoreRemoteStoreAction;
import org.opensearch.action.admin.cluster.remotestore.restore.RestoreRemoteStoreRequest;
Expand Down Expand Up @@ -286,6 +287,9 @@
import org.opensearch.action.admin.indices.rollover.RolloverRequestBuilder;
import org.opensearch.action.admin.indices.rollover.RolloverResponse;
import org.opensearch.action.admin.indices.scale.searchonly.ScaleIndexRequestBuilder;
import org.opensearch.action.admin.indices.streamingingestion.pause.PauseIngestionAction;
import org.opensearch.action.admin.indices.streamingingestion.resume.ResumeIngestionAction;
import org.opensearch.action.admin.indices.streamingingestion.state.GetIngestionStateAction;
import org.opensearch.action.admin.indices.segments.IndicesSegmentResponse;
import org.opensearch.action.admin.indices.segments.IndicesSegmentsAction;
import org.opensearch.action.admin.indices.segments.IndicesSegmentsRequest;
Expand Down Expand Up @@ -339,6 +343,10 @@
import org.opensearch.action.admin.indices.validate.query.ValidateQueryRequest;
import org.opensearch.action.admin.indices.validate.query.ValidateQueryRequestBuilder;
import org.opensearch.action.admin.indices.validate.query.ValidateQueryResponse;
import org.opensearch.action.admin.indices.view.CreateViewAction;
import org.opensearch.action.admin.indices.view.DeleteViewAction;
import org.opensearch.action.admin.indices.view.GetViewAction;
import org.opensearch.action.admin.indices.view.UpdateViewAction;
import org.opensearch.action.bulk.BulkAction;
import org.opensearch.action.bulk.BulkRequest;
import org.opensearch.action.bulk.BulkRequestBuilder;
Expand Down Expand Up @@ -1521,13 +1529,13 @@ public void wlmStats(WlmStatsRequest request, ActionListener<WlmStatsResponse> l

@Override
public RemoteStoreMetadataRequestBuilder prepareRemoteStoreMetadata(final String clusterUUID, final String clusterName) {
throw new UnsupportedOperationException("prepareRemoteStoreMetadata is not supported");
return new RemoteStoreMetadataRequestBuilder(this, RemoteStoreMetadataAction.INSTANCE);
}

@Override
public void remoteStoreMetadata(org.opensearch.action.admin.cluster.remotestore.metadata.RemoteStoreMetadataRequest request,
org.opensearch.core.action.ActionListener<org.opensearch.action.admin.cluster.remotestore.metadata.RemoteStoreMetadataResponse> listener) {
throw new UnsupportedOperationException("remoteStoreMetadata is not supported");
execute(RemoteStoreMetadataAction.INSTANCE, request, listener);
}

}
Expand Down Expand Up @@ -2087,83 +2095,83 @@ public SegmentReplicationStatsRequestBuilder prepareSegmentReplicationStats(fina
@Override
public void createView(org.opensearch.action.admin.indices.view.CreateViewAction.Request request,
ActionListener<org.opensearch.action.admin.indices.view.GetViewAction.Response> listener) {
throw new UnsupportedOperationException("Not implemented yet");
execute(CreateViewAction.INSTANCE, request, listener);
}

@Override
public ActionFuture<org.opensearch.action.admin.indices.view.GetViewAction.Response> createView(
org.opensearch.action.admin.indices.view.CreateViewAction.Request request) {
throw new UnsupportedOperationException("Not implemented yet");
return execute(CreateViewAction.INSTANCE, request);
}

@Override
public void getView(org.opensearch.action.admin.indices.view.GetViewAction.Request request,
ActionListener<org.opensearch.action.admin.indices.view.GetViewAction.Response> listener) {
throw new UnsupportedOperationException("Not implemented yet");
execute(GetViewAction.INSTANCE, request, listener);
}

@Override
public ActionFuture<org.opensearch.action.admin.indices.view.GetViewAction.Response> getView(
org.opensearch.action.admin.indices.view.GetViewAction.Request request) {
throw new UnsupportedOperationException("Not implemented yet");
return execute(GetViewAction.INSTANCE, request);
}

@Override
public void deleteView(org.opensearch.action.admin.indices.view.DeleteViewAction.Request request,
ActionListener<AcknowledgedResponse> listener) {
throw new UnsupportedOperationException("Not implemented yet");
execute(DeleteViewAction.INSTANCE, request, listener);
}

@Override
public ActionFuture<AcknowledgedResponse> deleteView(org.opensearch.action.admin.indices.view.DeleteViewAction.Request request) {
throw new UnsupportedOperationException("Not implemented yet");
return execute(DeleteViewAction.INSTANCE, request);
}

@Override
public void updateView(org.opensearch.action.admin.indices.view.CreateViewAction.Request request,
ActionListener<org.opensearch.action.admin.indices.view.GetViewAction.Response> listener) {
throw new UnsupportedOperationException("Not implemented yet");
execute(UpdateViewAction.INSTANCE, request, listener);
}

@Override
public ActionFuture<org.opensearch.action.admin.indices.view.GetViewAction.Response> updateView(
org.opensearch.action.admin.indices.view.CreateViewAction.Request request) {
throw new UnsupportedOperationException("Not implemented yet");
return execute(UpdateViewAction.INSTANCE, request);
}

@Override
public ActionFuture<PauseIngestionResponse> pauseIngestion(PauseIngestionRequest request) {
throw new UnsupportedOperationException("Not implemented yet");
return execute(PauseIngestionAction.INSTANCE, request);
}

@Override
public void pauseIngestion(PauseIngestionRequest request, ActionListener<PauseIngestionResponse> listener) {
throw new UnsupportedOperationException("Not implemented yet");
execute(PauseIngestionAction.INSTANCE, request, listener);
}

@Override
public ActionFuture<ResumeIngestionResponse> resumeIngestion(ResumeIngestionRequest request) {
throw new UnsupportedOperationException("Not implemented yet");
return execute(ResumeIngestionAction.INSTANCE, request);
}

@Override
public void resumeIngestion(ResumeIngestionRequest request, ActionListener<ResumeIngestionResponse> listener) {
throw new UnsupportedOperationException("Not implemented yet");
execute(ResumeIngestionAction.INSTANCE, request, listener);
}

@Override
public ActionFuture<GetIngestionStateResponse> getIngestionState(GetIngestionStateRequest request) {
throw new UnsupportedOperationException("Not implemented yet");
return execute(GetIngestionStateAction.INSTANCE, request);
}

@Override
public void getIngestionState(GetIngestionStateRequest request, ActionListener<GetIngestionStateResponse> listener) {
throw new UnsupportedOperationException("Not implemented yet");
execute(GetIngestionStateAction.INSTANCE, request, listener);
}

@Override
public ScaleIndexRequestBuilder prepareScaleSearchOnly(String index, boolean searchOnly) {
throw new UnsupportedOperationException("Not implemented yet");
return new ScaleIndexRequestBuilder(this, searchOnly, index);
}

}
Expand Down
91 changes: 86 additions & 5 deletions src/main/java/org/codelibs/fesen/client/HttpClient.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -105,6 +105,17 @@
import org.codelibs.fesen.client.action.HttpMultiTermVectorsAction;
import org.codelibs.fesen.client.action.HttpNodesInfoAction;
import org.codelibs.fesen.client.action.HttpNodesUsageAction;
import org.codelibs.fesen.client.action.HttpCreateViewAction;
import org.codelibs.fesen.client.action.HttpGetViewAction;
import org.codelibs.fesen.client.action.HttpDeleteViewAction;
import org.codelibs.fesen.client.action.HttpUpdateViewAction;
import org.codelibs.fesen.client.action.HttpSearchViewAction;
import org.codelibs.fesen.client.action.HttpListViewNamesAction;
import org.codelibs.fesen.client.action.HttpPauseIngestionAction;
import org.codelibs.fesen.client.action.HttpResumeIngestionAction;
import org.codelibs.fesen.client.action.HttpGetIngestionStateAction;
import org.codelibs.fesen.client.action.HttpScaleIndexAction;
import org.codelibs.fesen.client.action.HttpRemoteStoreMetadataAction;
import org.codelibs.fesen.client.action.HttpRecoveryAction;
import org.codelibs.fesen.client.action.HttpRemoteInfoAction;
import org.codelibs.fesen.client.action.HttpTermVectorsAction;
Expand Down Expand Up @@ -217,6 +228,25 @@
import org.opensearch.action.admin.cluster.wlm.WlmStatsAction;
import org.opensearch.action.admin.cluster.wlm.WlmStatsRequest;
import org.opensearch.action.admin.cluster.wlm.WlmStatsResponse;
import org.opensearch.action.admin.indices.view.CreateViewAction;
import org.opensearch.action.admin.indices.view.GetViewAction;
import org.opensearch.action.admin.indices.view.DeleteViewAction;
import org.opensearch.action.admin.indices.view.UpdateViewAction;
import org.opensearch.action.admin.indices.view.SearchViewAction;
import org.opensearch.action.admin.indices.view.ListViewNamesAction;
import org.opensearch.action.admin.indices.streamingingestion.pause.PauseIngestionAction;
import org.opensearch.action.admin.indices.streamingingestion.pause.PauseIngestionRequest;
import org.opensearch.action.admin.indices.streamingingestion.pause.PauseIngestionResponse;
import org.opensearch.action.admin.indices.streamingingestion.resume.ResumeIngestionAction;
import org.opensearch.action.admin.indices.streamingingestion.resume.ResumeIngestionRequest;
import org.opensearch.action.admin.indices.streamingingestion.resume.ResumeIngestionResponse;
import org.opensearch.action.admin.indices.streamingingestion.state.GetIngestionStateAction;
import org.opensearch.action.admin.indices.streamingingestion.state.GetIngestionStateRequest;
import org.opensearch.action.admin.indices.streamingingestion.state.GetIngestionStateResponse;
import org.opensearch.action.admin.indices.scale.searchonly.ScaleIndexAction;
import org.opensearch.action.admin.cluster.remotestore.metadata.RemoteStoreMetadataAction;
import org.opensearch.action.admin.cluster.remotestore.metadata.RemoteStoreMetadataRequest;
import org.opensearch.action.admin.cluster.remotestore.metadata.RemoteStoreMetadataResponse;
import org.opensearch.action.admin.indices.alias.IndicesAliasesAction;
import org.opensearch.action.admin.indices.alias.IndicesAliasesRequest;
import org.opensearch.action.admin.indices.alias.get.GetAliasesAction;
Expand Down Expand Up @@ -1018,6 +1048,57 @@ public HttpClient(final Settings settings, final ThreadPool threadPool, final Li
new HttpMultiTermVectorsAction(this, MultiTermVectorsAction.INSTANCE).execute((MultiTermVectorsRequest) request,
actionListener);
});

// View API
actions.put(CreateViewAction.INSTANCE, (request, listener) -> {
new HttpCreateViewAction(this, CreateViewAction.INSTANCE).execute((CreateViewAction.Request) request,
(ActionListener<GetViewAction.Response>) listener);
});
actions.put(GetViewAction.INSTANCE, (request, listener) -> {
new HttpGetViewAction(this, GetViewAction.INSTANCE).execute((GetViewAction.Request) request,
(ActionListener<GetViewAction.Response>) listener);
});
actions.put(DeleteViewAction.INSTANCE, (request, listener) -> {
new HttpDeleteViewAction(this, DeleteViewAction.INSTANCE).execute((DeleteViewAction.Request) request,
(ActionListener<AcknowledgedResponse>) listener);
});
actions.put(UpdateViewAction.INSTANCE, (request, listener) -> {
new HttpUpdateViewAction(this, UpdateViewAction.INSTANCE).execute((CreateViewAction.Request) request,
(ActionListener<GetViewAction.Response>) listener);
});
actions.put(SearchViewAction.INSTANCE, (request, listener) -> {
new HttpSearchViewAction(this, SearchViewAction.INSTANCE).execute((SearchViewAction.Request) request,
(ActionListener<SearchResponse>) listener);
});
actions.put(ListViewNamesAction.INSTANCE, (request, listener) -> {
new HttpListViewNamesAction(this, ListViewNamesAction.INSTANCE).execute((ListViewNamesAction.Request) request,
(ActionListener<ListViewNamesAction.Response>) listener);
});

// Streaming Ingestion API
actions.put(PauseIngestionAction.INSTANCE, (request, listener) -> {
new HttpPauseIngestionAction(this, PauseIngestionAction.INSTANCE).execute((PauseIngestionRequest) request,
(ActionListener<PauseIngestionResponse>) listener);
});
actions.put(ResumeIngestionAction.INSTANCE, (request, listener) -> {
new HttpResumeIngestionAction(this, ResumeIngestionAction.INSTANCE).execute((ResumeIngestionRequest) request,
(ActionListener<ResumeIngestionResponse>) listener);
});
actions.put(GetIngestionStateAction.INSTANCE, (request, listener) -> {
new HttpGetIngestionStateAction(this, GetIngestionStateAction.INSTANCE).execute((GetIngestionStateRequest) request,
(ActionListener<GetIngestionStateResponse>) listener);
});

// Scale (Search-Only) API
actions.put(ScaleIndexAction.INSTANCE, (request, listener) -> {
new HttpScaleIndexAction(this, ScaleIndexAction.INSTANCE).execute(request, (ActionListener<AcknowledgedResponse>) listener);
});

// Remote Store Metadata API
actions.put(RemoteStoreMetadataAction.INSTANCE, (request, listener) -> {
new HttpRemoteStoreMetadataAction(this, RemoteStoreMetadataAction.INSTANCE).execute((RemoteStoreMetadataRequest) request,
(ActionListener<RemoteStoreMetadataResponse>) listener);
});
}

@Override
Expand Down Expand Up @@ -1288,29 +1369,29 @@ protected WorkerThread(final ForkJoinPool pool) {
@Override
public void searchView(org.opensearch.action.admin.indices.view.SearchViewAction.Request request,
ActionListener<SearchResponse> listener) {
throw new UnsupportedOperationException("Not implemented yet");
execute(SearchViewAction.INSTANCE, request, listener);
}

@Override
public ActionFuture<SearchResponse> searchView(org.opensearch.action.admin.indices.view.SearchViewAction.Request request) {
throw new UnsupportedOperationException("Not implemented yet");
return execute(SearchViewAction.INSTANCE, request);
}

@Override
public void listViewNames(org.opensearch.action.admin.indices.view.ListViewNamesAction.Request request,
ActionListener<org.opensearch.action.admin.indices.view.ListViewNamesAction.Response> listener) {
throw new UnsupportedOperationException("Not implemented yet");
execute(ListViewNamesAction.INSTANCE, request, listener);
}

@Override
public ActionFuture<org.opensearch.action.admin.indices.view.ListViewNamesAction.Response> listViewNames(
org.opensearch.action.admin.indices.view.ListViewNamesAction.Request request) {
throw new UnsupportedOperationException("Not implemented yet");
return execute(ListViewNamesAction.INSTANCE, request);
}

@Override
public SearchRequestBuilder prepareStreamSearch(final String... indices) {
throw new UnsupportedOperationException("prepareStreamSearch is not supported");
return new SearchRequestBuilder(this, SearchAction.INSTANCE).setIndices(indices);
}

}
Loading
Loading