Skip to content

Commit

Permalink
Rename class DeleteDecommissionStateAction
Browse files Browse the repository at this point in the history
Signed-off-by: pranikum <[email protected]>
  • Loading branch information
pranikum committed Sep 22, 2022
1 parent 89eff69 commit 86f8c54
Show file tree
Hide file tree
Showing 5 changed files with 11 additions and 11 deletions.
4 changes: 2 additions & 2 deletions server/src/main/java/org/opensearch/action/ActionModule.java
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@
import org.opensearch.action.admin.cluster.configuration.ClearVotingConfigExclusionsAction;
import org.opensearch.action.admin.cluster.configuration.TransportAddVotingConfigExclusionsAction;
import org.opensearch.action.admin.cluster.configuration.TransportClearVotingConfigExclusionsAction;
import org.opensearch.action.admin.cluster.decommission.awareness.delete.DeleteDecommissionAction;
import org.opensearch.action.admin.cluster.decommission.awareness.delete.DeleteDecommissionStateAction;
import org.opensearch.action.admin.cluster.decommission.awareness.delete.TransportDeleteDecommissionAction;
import org.opensearch.action.admin.cluster.health.ClusterHealthAction;
import org.opensearch.action.admin.cluster.health.TransportClusterHealthAction;
Expand Down Expand Up @@ -565,7 +565,7 @@ public <Request extends ActionRequest, Response extends ActionResponse> void reg
actions.register(CloneSnapshotAction.INSTANCE, TransportCloneSnapshotAction.class);
actions.register(RestoreSnapshotAction.INSTANCE, TransportRestoreSnapshotAction.class);
actions.register(SnapshotsStatusAction.INSTANCE, TransportSnapshotsStatusAction.class);
actions.register(DeleteDecommissionAction.INSTANCE, TransportDeleteDecommissionAction.class);
actions.register(DeleteDecommissionStateAction.INSTANCE, TransportDeleteDecommissionAction.class);

actions.register(IndicesStatsAction.INSTANCE, TransportIndicesStatsAction.class);
actions.register(IndicesSegmentsAction.INSTANCE, TransportIndicesSegmentsAction.class);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ public class DeleteDecommissionRequestBuilder extends ClusterManagerNodeOperatio
DeleteDecommissionResponse,
DeleteDecommissionRequestBuilder> {

public DeleteDecommissionRequestBuilder(OpenSearchClient client, DeleteDecommissionAction action) {
public DeleteDecommissionRequestBuilder(OpenSearchClient client, DeleteDecommissionStateAction action) {
super(client, action, new DeleteDecommissionRequest());
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -16,11 +16,11 @@
* @opensearch.internal
*/

public class DeleteDecommissionAction extends ActionType<DeleteDecommissionResponse> {
public static final DeleteDecommissionAction INSTANCE = new DeleteDecommissionAction();
public class DeleteDecommissionStateAction extends ActionType<DeleteDecommissionResponse> {
public static final DeleteDecommissionStateAction INSTANCE = new DeleteDecommissionStateAction();
public static final String NAME = "cluster:admin/decommission/awareness/delete";

private DeleteDecommissionAction() {
private DeleteDecommissionStateAction() {
super(NAME, DeleteDecommissionResponse::new);
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@ public TransportDeleteDecommissionAction(
IndexNameExpressionResolver indexNameExpressionResolver
) {
super(
DeleteDecommissionAction.NAME,
DeleteDecommissionStateAction.NAME,
transportService,
clusterService,
threadPool,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@
import org.opensearch.action.admin.cluster.allocation.ClusterAllocationExplainRequest;
import org.opensearch.action.admin.cluster.allocation.ClusterAllocationExplainRequestBuilder;
import org.opensearch.action.admin.cluster.allocation.ClusterAllocationExplainResponse;
import org.opensearch.action.admin.cluster.decommission.awareness.delete.DeleteDecommissionAction;
import org.opensearch.action.admin.cluster.decommission.awareness.delete.DeleteDecommissionStateAction;
import org.opensearch.action.admin.cluster.decommission.awareness.delete.DeleteDecommissionRequest;
import org.opensearch.action.admin.cluster.decommission.awareness.delete.DeleteDecommissionRequestBuilder;
import org.opensearch.action.admin.cluster.decommission.awareness.delete.DeleteDecommissionResponse;
Expand Down Expand Up @@ -1270,17 +1270,17 @@ public ActionFuture<AcknowledgedResponse> deleteDanglingIndex(DeleteDanglingInde

@Override
public ActionFuture<DeleteDecommissionResponse> deleteDecommission(DeleteDecommissionRequest request) {
return execute(DeleteDecommissionAction.INSTANCE, request);
return execute(DeleteDecommissionStateAction.INSTANCE, request);
}

@Override
public void deleteDecommission(DeleteDecommissionRequest request, ActionListener<DeleteDecommissionResponse> listener) {
execute(DeleteDecommissionAction.INSTANCE, request, listener);
execute(DeleteDecommissionStateAction.INSTANCE, request, listener);
}

@Override
public DeleteDecommissionRequestBuilder prepareDeleteDecommission() {
return new DeleteDecommissionRequestBuilder(this, DeleteDecommissionAction.INSTANCE);
return new DeleteDecommissionRequestBuilder(this, DeleteDecommissionStateAction.INSTANCE);
}

@Override
Expand Down

0 comments on commit 86f8c54

Please sign in to comment.