Rename Action to ActionType (#43778)
Action is a class that encapsulates meta information about an action that allows it to be called remotely, specifically the action name and response type. With recent refactoring, the action class can now be constructed as a static constant, instead of needing to create a subclass. This makes the old pattern of creating a singleton INSTANCE both misnamed and lacking a common placement. This commit renames Action to ActionType, thus allowing the old INSTANCE naming pattern to be TYPE on the transport action itself. ActionType also conveys that this class is also not the action itself, although this change does not rename any concrete classes as those will be removed organically as they are converted to TYPE constants. relates #34389
This commit is contained in:
Ryan Ernst
GitHub
parent
8f49d01113
commit
3a2c698ce0
|
|
@ -18,10 +18,10 @@
|
|||
*/
|
||||
package org.elasticsearch.plugin.noop.action.bulk;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
import org.elasticsearch.action.bulk.BulkResponse;
|
||||
|
||||
public class NoopBulkAction extends StreamableResponseAction<BulkResponse> {
|
||||
public class NoopBulkAction extends StreamableResponseActionType<BulkResponse> {
|
||||
public static final String NAME = "mock:data/write/bulk";
|
||||
|
||||
public static final NoopBulkAction INSTANCE = new NoopBulkAction();
|
||||
|
|
|
|||
|
|
@ -18,11 +18,11 @@
|
|||
*/
|
||||
package org.elasticsearch.plugin.noop.action.search;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.search.SearchResponse;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
public class NoopSearchAction extends Action<SearchResponse> {
|
||||
public class NoopSearchAction extends ActionType<SearchResponse> {
|
||||
public static final NoopSearchAction INSTANCE = new NoopSearchAction();
|
||||
public static final String NAME = "mock:data/read/search";
|
||||
|
||||
|
|
|
|||
|
|
@ -22,7 +22,7 @@ import org.elasticsearch.action.ActionListener;
|
|||
import org.elasticsearch.action.ActionRequest;
|
||||
import org.elasticsearch.action.ActionRequestValidationException;
|
||||
import org.elasticsearch.action.ActionResponse;
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
import org.elasticsearch.action.support.ActionFilters;
|
||||
import org.elasticsearch.action.support.HandledTransportAction;
|
||||
import org.elasticsearch.client.node.NodeClient;
|
||||
|
|
@ -45,7 +45,7 @@ import java.util.Map;
|
|||
import static org.elasticsearch.ingest.common.IngestCommonPlugin.GROK_PATTERNS;
|
||||
import static org.elasticsearch.rest.RestRequest.Method.GET;
|
||||
|
||||
public class GrokProcessorGetAction extends StreamableResponseAction<GrokProcessorGetAction.Response> {
|
||||
public class GrokProcessorGetAction extends StreamableResponseActionType<GrokProcessorGetAction.Response> {
|
||||
|
||||
static final GrokProcessorGetAction INSTANCE = new GrokProcessorGetAction();
|
||||
static final String NAME = "cluster:admin/ingest/processor/grok/get";
|
||||
|
|
|
|||
|
|
@ -19,10 +19,10 @@
|
|||
|
||||
package org.elasticsearch.script.mustache;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
public class MultiSearchTemplateAction extends Action<MultiSearchTemplateResponse> {
|
||||
public class MultiSearchTemplateAction extends ActionType<MultiSearchTemplateResponse> {
|
||||
|
||||
public static final MultiSearchTemplateAction INSTANCE = new MultiSearchTemplateAction();
|
||||
public static final String NAME = "indices:data/read/msearch/template";
|
||||
|
|
|
|||
|
|
@ -19,10 +19,10 @@
|
|||
|
||||
package org.elasticsearch.script.mustache;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
public class SearchTemplateAction extends Action<SearchTemplateResponse> {
|
||||
public class SearchTemplateAction extends ActionType<SearchTemplateResponse> {
|
||||
|
||||
public static final SearchTemplateAction INSTANCE = new SearchTemplateAction();
|
||||
public static final String NAME = "indices:data/read/search/template";
|
||||
|
|
|
|||
|
|
@ -19,7 +19,7 @@
|
|||
|
||||
package org.elasticsearch.painless.action;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.ActionListener;
|
||||
import org.elasticsearch.action.ActionRequest;
|
||||
import org.elasticsearch.action.ActionRequestValidationException;
|
||||
|
|
@ -64,7 +64,7 @@ import static org.elasticsearch.rest.RestRequest.Method.GET;
|
|||
* retrieves all available information about the API for this specific context</li>
|
||||
* </ul>
|
||||
*/
|
||||
public class PainlessContextAction extends Action<PainlessContextAction.Response> {
|
||||
public class PainlessContextAction extends ActionType<PainlessContextAction.Response> {
|
||||
|
||||
public static final PainlessContextAction INSTANCE = new PainlessContextAction();
|
||||
private static final String NAME = "cluster:admin/scripts/painless/context";
|
||||
|
|
|
|||
|
|
@ -31,7 +31,7 @@ import org.apache.lucene.search.Scorer;
|
|||
import org.apache.lucene.search.Weight;
|
||||
import org.apache.lucene.store.RAMDirectory;
|
||||
import org.elasticsearch.Version;
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.ActionRequestValidationException;
|
||||
import org.elasticsearch.action.ActionResponse;
|
||||
import org.elasticsearch.action.support.ActionFilters;
|
||||
|
|
@ -92,7 +92,7 @@ import static org.elasticsearch.action.ValidateActions.addValidationError;
|
|||
import static org.elasticsearch.rest.RestRequest.Method.GET;
|
||||
import static org.elasticsearch.rest.RestRequest.Method.POST;
|
||||
|
||||
public class PainlessExecuteAction extends Action<PainlessExecuteAction.Response> {
|
||||
public class PainlessExecuteAction extends ActionType<PainlessExecuteAction.Response> {
|
||||
|
||||
public static final PainlessExecuteAction INSTANCE = new PainlessExecuteAction();
|
||||
private static final String NAME = "cluster:admin/scripts/painless/execute";
|
||||
|
|
|
|||
|
|
@ -19,12 +19,12 @@
|
|||
|
||||
package org.elasticsearch.index.rankeval;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
/**
|
||||
* Action for explaining evaluating search ranking results.
|
||||
* ActionType for explaining evaluating search ranking results.
|
||||
*/
|
||||
public class RankEvalAction extends StreamableResponseAction<RankEvalResponse> {
|
||||
public class RankEvalAction extends StreamableResponseActionType<RankEvalResponse> {
|
||||
|
||||
public static final RankEvalAction INSTANCE = new RankEvalAction();
|
||||
public static final String NAME = "indices:data/read/rank_eval";
|
||||
|
|
|
|||
|
|
@ -19,13 +19,13 @@
|
|||
|
||||
package org.elasticsearch.index.rankeval;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.ActionRequestBuilder;
|
||||
import org.elasticsearch.client.ElasticsearchClient;
|
||||
|
||||
public class RankEvalRequestBuilder extends ActionRequestBuilder<RankEvalRequest, RankEvalResponse> {
|
||||
|
||||
public RankEvalRequestBuilder(ElasticsearchClient client, Action<RankEvalResponse> action,
|
||||
public RankEvalRequestBuilder(ElasticsearchClient client, ActionType<RankEvalResponse> action,
|
||||
RankEvalRequest request) {
|
||||
super(client, action, request);
|
||||
}
|
||||
|
|
|
|||
|
|
@ -19,7 +19,7 @@
|
|||
|
||||
package org.elasticsearch.index.reindex;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.ActionRequestValidationException;
|
||||
import org.elasticsearch.action.support.ActiveShardCount;
|
||||
import org.elasticsearch.client.node.NodeClient;
|
||||
|
|
@ -38,7 +38,7 @@ import java.util.Map;
|
|||
|
||||
public abstract class AbstractBaseReindexRestHandler<
|
||||
Request extends AbstractBulkByScrollRequest<Request>,
|
||||
A extends Action<BulkByScrollResponse>
|
||||
A extends ActionType<BulkByScrollResponse>
|
||||
> extends BaseRestHandler {
|
||||
|
||||
private final A action;
|
||||
|
|
|
|||
|
|
@ -19,7 +19,7 @@
|
|||
|
||||
package org.elasticsearch.index.reindex;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.search.SearchRequest;
|
||||
import org.elasticsearch.common.bytes.BytesReference;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
|
|
@ -39,7 +39,7 @@ import java.util.function.Consumer;
|
|||
*/
|
||||
public abstract class AbstractBulkByQueryRestHandler<
|
||||
Request extends AbstractBulkByScrollRequest<Request>,
|
||||
A extends Action<BulkByScrollResponse>> extends AbstractBaseReindexRestHandler<Request, A> {
|
||||
A extends ActionType<BulkByScrollResponse>> extends AbstractBaseReindexRestHandler<Request, A> {
|
||||
|
||||
protected AbstractBulkByQueryRestHandler(Settings settings, A action) {
|
||||
super(settings, action);
|
||||
|
|
|
|||
|
|
@ -19,7 +19,7 @@
|
|||
|
||||
package org.elasticsearch.index.reindex;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.ActionListener;
|
||||
import org.elasticsearch.action.admin.cluster.shards.ClusterSearchShardsRequest;
|
||||
import org.elasticsearch.action.admin.cluster.shards.ClusterSearchShardsResponse;
|
||||
|
|
@ -61,7 +61,7 @@ class BulkByScrollParallelizationHelper {
|
|||
static <Request extends AbstractBulkByScrollRequest<Request>> void startSlicedAction(
|
||||
Request request,
|
||||
BulkByScrollTask task,
|
||||
Action<BulkByScrollResponse> action,
|
||||
ActionType<BulkByScrollResponse> action,
|
||||
ActionListener<BulkByScrollResponse> listener,
|
||||
Client client,
|
||||
DiscoveryNode node,
|
||||
|
|
@ -85,7 +85,7 @@ class BulkByScrollParallelizationHelper {
|
|||
private static <Request extends AbstractBulkByScrollRequest<Request>> void sliceConditionally(
|
||||
Request request,
|
||||
BulkByScrollTask task,
|
||||
Action<BulkByScrollResponse> action,
|
||||
ActionType<BulkByScrollResponse> action,
|
||||
ActionListener<BulkByScrollResponse> listener,
|
||||
Client client,
|
||||
DiscoveryNode node,
|
||||
|
|
@ -118,7 +118,7 @@ class BulkByScrollParallelizationHelper {
|
|||
|
||||
private static <Request extends AbstractBulkByScrollRequest<Request>> void sendSubRequests(
|
||||
Client client,
|
||||
Action<BulkByScrollResponse> action,
|
||||
ActionType<BulkByScrollResponse> action,
|
||||
String localNodeId,
|
||||
BulkByScrollTask task,
|
||||
Request request,
|
||||
|
|
|
|||
|
|
@ -19,11 +19,11 @@
|
|||
|
||||
package org.elasticsearch.index.reindex;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.admin.cluster.node.tasks.list.ListTasksResponse;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
public class RethrottleAction extends Action<ListTasksResponse> {
|
||||
public class RethrottleAction extends ActionType<ListTasksResponse> {
|
||||
public static final RethrottleAction INSTANCE = new RethrottleAction();
|
||||
public static final String NAME = "cluster:admin/reindex/rethrottle";
|
||||
|
||||
|
|
|
|||
|
|
@ -19,7 +19,7 @@
|
|||
|
||||
package org.elasticsearch.index.reindex;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.admin.cluster.node.tasks.list.ListTasksResponse;
|
||||
import org.elasticsearch.action.support.tasks.TasksRequestBuilder;
|
||||
import org.elasticsearch.client.ElasticsearchClient;
|
||||
|
|
@ -29,7 +29,7 @@ import org.elasticsearch.client.ElasticsearchClient;
|
|||
*/
|
||||
public class RethrottleRequestBuilder extends TasksRequestBuilder<RethrottleRequest, ListTasksResponse, RethrottleRequestBuilder> {
|
||||
public RethrottleRequestBuilder(ElasticsearchClient client,
|
||||
Action<ListTasksResponse> action) {
|
||||
ActionType<ListTasksResponse> action) {
|
||||
super(client, action, new RethrottleRequest());
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -23,7 +23,7 @@ import org.apache.lucene.search.TotalHits;
|
|||
import org.elasticsearch.ElasticsearchException;
|
||||
import org.elasticsearch.ExceptionsHelper;
|
||||
import org.elasticsearch.Version;
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.ActionListener;
|
||||
import org.elasticsearch.action.ActionRequest;
|
||||
import org.elasticsearch.action.ActionResponse;
|
||||
|
|
@ -761,7 +761,7 @@ public class AsyncBulkByScrollActionTests extends ESTestCase {
|
|||
@Override
|
||||
@SuppressWarnings("unchecked")
|
||||
protected <Request extends ActionRequest, Response extends ActionResponse>
|
||||
void doExecute(Action<Response> action, Request request, ActionListener<Response> listener) {
|
||||
void doExecute(ActionType<Response> action, Request request, ActionListener<Response> listener) {
|
||||
if (false == expectedHeaders.equals(threadPool().getThreadContext().getHeaders())) {
|
||||
listener.onFailure(
|
||||
new RuntimeException("Expected " + expectedHeaders + " but got " + threadPool().getThreadContext().getHeaders()));
|
||||
|
|
|
|||
|
|
@ -167,7 +167,7 @@ public class ReindexFromRemoteWithAuthTests extends ESSingleNodeTestCase {
|
|||
}
|
||||
|
||||
/**
|
||||
* Action filter that will reject the request if it isn't authenticated.
|
||||
* ActionType filter that will reject the request if it isn't authenticated.
|
||||
*/
|
||||
public static class TestFilter implements ActionFilter {
|
||||
/**
|
||||
|
|
|
|||
|
|
@ -424,7 +424,7 @@ public class ActionModule extends AbstractModule {
|
|||
}
|
||||
|
||||
public <Request extends ActionRequest, Response extends ActionResponse> void register(
|
||||
Action<Response> action, Class<? extends TransportAction<Request, Response>> transportAction,
|
||||
ActionType<Response> action, Class<? extends TransportAction<Request, Response>> transportAction,
|
||||
Class<?>... supportTransportActions) {
|
||||
register(new ActionHandler<>(action, transportAction, supportTransportActions));
|
||||
}
|
||||
|
|
@ -703,10 +703,10 @@ public class ActionModule extends AbstractModule {
|
|||
bind(AutoCreateIndex.class).toInstance(autoCreateIndex);
|
||||
bind(TransportLivenessAction.class).asEagerSingleton();
|
||||
|
||||
// register Action -> transportAction Map used by NodeClient
|
||||
// register ActionType -> transportAction Map used by NodeClient
|
||||
@SuppressWarnings("rawtypes")
|
||||
MapBinder<Action, TransportAction> transportActionsBinder
|
||||
= MapBinder.newMapBinder(binder(), Action.class, TransportAction.class);
|
||||
MapBinder<ActionType, TransportAction> transportActionsBinder
|
||||
= MapBinder.newMapBinder(binder(), ActionType.class, TransportAction.class);
|
||||
for (ActionHandler<?, ?> action : actions.values()) {
|
||||
// bind the action as eager singleton, so the map binder one will reuse it
|
||||
bind(action.getTransportAction()).asEagerSingleton();
|
||||
|
|
|
|||
|
|
@ -26,11 +26,11 @@ import java.util.Objects;
|
|||
|
||||
public abstract class ActionRequestBuilder<Request extends ActionRequest, Response extends ActionResponse> {
|
||||
|
||||
protected final Action<Response> action;
|
||||
protected final ActionType<Response> action;
|
||||
protected final Request request;
|
||||
protected final ElasticsearchClient client;
|
||||
|
||||
protected ActionRequestBuilder(ElasticsearchClient client, Action<Response> action, Request request) {
|
||||
protected ActionRequestBuilder(ElasticsearchClient client, ActionType<Response> action, Request request) {
|
||||
Objects.requireNonNull(action, "action must not be null");
|
||||
this.action = action;
|
||||
this.request = request;
|
||||
|
|
|
|||
|
|
@ -26,7 +26,7 @@ import org.elasticsearch.transport.TransportRequestOptions;
|
|||
/**
|
||||
* A generic action. Should strive to make it a singleton.
|
||||
*/
|
||||
public class Action<Response extends ActionResponse> {
|
||||
public class ActionType<Response extends ActionResponse> {
|
||||
|
||||
private final String name;
|
||||
private final Writeable.Reader<Response> responseReader;
|
||||
|
|
@ -36,7 +36,7 @@ public class Action<Response extends ActionResponse> {
|
|||
* @deprecated Pass a {@link Writeable.Reader} with {@link }
|
||||
*/
|
||||
@Deprecated
|
||||
protected Action(String name) {
|
||||
protected ActionType(String name) {
|
||||
this(name, null);
|
||||
}
|
||||
|
||||
|
|
@ -44,7 +44,7 @@ public class Action<Response extends ActionResponse> {
|
|||
* @param name The name of the action, must be unique across actions.
|
||||
* @param responseReader A reader for the response type
|
||||
*/
|
||||
public Action(String name, Writeable.Reader<Response> responseReader) {
|
||||
public ActionType(String name, Writeable.Reader<Response> responseReader) {
|
||||
this.name = name;
|
||||
this.responseReader = responseReader;
|
||||
}
|
||||
|
|
@ -72,7 +72,7 @@ public class Action<Response extends ActionResponse> {
|
|||
|
||||
@Override
|
||||
public boolean equals(Object o) {
|
||||
return o instanceof Action && name.equals(((Action<?>) o).name());
|
||||
return o instanceof ActionType && name.equals(((ActionType<?>) o).name());
|
||||
}
|
||||
|
||||
@Override
|
||||
|
|
@ -23,12 +23,12 @@ import org.elasticsearch.common.io.stream.Writeable;
|
|||
|
||||
/**
|
||||
* An action for with the response type implements {@link org.elasticsearch.common.io.stream.Streamable}.
|
||||
* @deprecated Use {@link Action} directly and provide a {@link Writeable.Reader}
|
||||
* @deprecated Use {@link ActionType} directly and provide a {@link Writeable.Reader}
|
||||
*/
|
||||
@Deprecated
|
||||
public abstract class StreamableResponseAction<Response extends ActionResponse> extends Action<Response> {
|
||||
public abstract class StreamableResponseActionType<Response extends ActionResponse> extends ActionType<Response> {
|
||||
|
||||
protected StreamableResponseAction(String name) {
|
||||
protected StreamableResponseActionType(String name) {
|
||||
super(name);
|
||||
}
|
||||
|
||||
|
|
@ -30,10 +30,10 @@ import org.elasticsearch.transport.TransportService;
|
|||
public class TransportActionNodeProxy<Request extends ActionRequest, Response extends ActionResponse> {
|
||||
|
||||
private final TransportService transportService;
|
||||
private final Action<Response> action;
|
||||
private final ActionType<Response> action;
|
||||
private final TransportRequestOptions transportOptions;
|
||||
|
||||
public TransportActionNodeProxy(Settings settings, Action<Response> action, TransportService transportService) {
|
||||
public TransportActionNodeProxy(Settings settings, ActionType<Response> action, TransportService transportService) {
|
||||
this.action = action;
|
||||
this.transportService = transportService;
|
||||
this.transportOptions = action.transportOptions(settings);
|
||||
|
|
|
|||
|
|
@ -19,12 +19,12 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.allocation;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
/**
|
||||
* Action for explaining shard allocation for a shard in the cluster
|
||||
* ActionType for explaining shard allocation for a shard in the cluster
|
||||
*/
|
||||
public class ClusterAllocationExplainAction extends StreamableResponseAction<ClusterAllocationExplainResponse> {
|
||||
public class ClusterAllocationExplainAction extends StreamableResponseActionType<ClusterAllocationExplainResponse> {
|
||||
|
||||
public static final ClusterAllocationExplainAction INSTANCE = new ClusterAllocationExplainAction();
|
||||
public static final String NAME = "cluster:monitor/allocation/explain";
|
||||
|
|
|
|||
|
|
@ -18,10 +18,10 @@
|
|||
*/
|
||||
package org.elasticsearch.action.admin.cluster.configuration;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.common.io.stream.Writeable.Reader;
|
||||
|
||||
public class AddVotingConfigExclusionsAction extends Action<AddVotingConfigExclusionsResponse> {
|
||||
public class AddVotingConfigExclusionsAction extends ActionType<AddVotingConfigExclusionsResponse> {
|
||||
public static final AddVotingConfigExclusionsAction INSTANCE = new AddVotingConfigExclusionsAction();
|
||||
public static final String NAME = "cluster:admin/voting_config/add_exclusions";
|
||||
|
||||
|
|
|
|||
|
|
@ -18,10 +18,10 @@
|
|||
*/
|
||||
package org.elasticsearch.action.admin.cluster.configuration;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.common.io.stream.Writeable.Reader;
|
||||
|
||||
public class ClearVotingConfigExclusionsAction extends Action<ClearVotingConfigExclusionsResponse> {
|
||||
public class ClearVotingConfigExclusionsAction extends ActionType<ClearVotingConfigExclusionsResponse> {
|
||||
public static final ClearVotingConfigExclusionsAction INSTANCE = new ClearVotingConfigExclusionsAction();
|
||||
public static final String NAME = "cluster:admin/voting_config/clear_exclusions";
|
||||
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.health;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class ClusterHealthAction extends StreamableResponseAction<ClusterHealthResponse> {
|
||||
public class ClusterHealthAction extends StreamableResponseActionType<ClusterHealthResponse> {
|
||||
|
||||
public static final ClusterHealthAction INSTANCE = new ClusterHealthAction();
|
||||
public static final String NAME = "cluster:monitor/health";
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.node.hotthreads;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class NodesHotThreadsAction extends StreamableResponseAction<NodesHotThreadsResponse> {
|
||||
public class NodesHotThreadsAction extends StreamableResponseActionType<NodesHotThreadsResponse> {
|
||||
|
||||
public static final NodesHotThreadsAction INSTANCE = new NodesHotThreadsAction();
|
||||
public static final String NAME = "cluster:monitor/nodes/hot_threads";
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.node.info;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class NodesInfoAction extends StreamableResponseAction<NodesInfoResponse> {
|
||||
public class NodesInfoAction extends StreamableResponseActionType<NodesInfoResponse> {
|
||||
|
||||
public static final NodesInfoAction INSTANCE = new NodesInfoAction();
|
||||
public static final String NAME = "cluster:monitor/nodes/info";
|
||||
|
|
|
|||
|
|
@ -19,10 +19,10 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.node.reload;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class NodesReloadSecureSettingsAction
|
||||
extends StreamableResponseAction<NodesReloadSecureSettingsResponse> {
|
||||
extends StreamableResponseActionType<NodesReloadSecureSettingsResponse> {
|
||||
|
||||
public static final NodesReloadSecureSettingsAction INSTANCE = new NodesReloadSecureSettingsAction();
|
||||
public static final String NAME = "cluster:admin/nodes/reload_secure_settings";
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.node.stats;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class NodesStatsAction extends StreamableResponseAction<NodesStatsResponse> {
|
||||
public class NodesStatsAction extends StreamableResponseActionType<NodesStatsResponse> {
|
||||
|
||||
public static final NodesStatsAction INSTANCE = new NodesStatsAction();
|
||||
public static final String NAME = "cluster:monitor/nodes/stats";
|
||||
|
|
|
|||
|
|
@ -19,13 +19,13 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.node.tasks.cancel;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
/**
|
||||
* Action for cancelling running tasks
|
||||
* ActionType for cancelling running tasks
|
||||
*/
|
||||
public class CancelTasksAction extends Action<CancelTasksResponse> {
|
||||
public class CancelTasksAction extends ActionType<CancelTasksResponse> {
|
||||
|
||||
public static final CancelTasksAction INSTANCE = new CancelTasksAction();
|
||||
public static final String NAME = "cluster:admin/tasks/cancel";
|
||||
|
|
|
|||
|
|
@ -19,12 +19,12 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.node.tasks.get;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
/**
|
||||
* Action for retrieving a list of currently running tasks
|
||||
* ActionType for retrieving a list of currently running tasks
|
||||
*/
|
||||
public class GetTaskAction extends StreamableResponseAction<GetTaskResponse> {
|
||||
public class GetTaskAction extends StreamableResponseActionType<GetTaskResponse> {
|
||||
public static final String TASKS_ORIGIN = "tasks";
|
||||
|
||||
public static final GetTaskAction INSTANCE = new GetTaskAction();
|
||||
|
|
|
|||
|
|
@ -56,7 +56,7 @@ import static org.elasticsearch.action.admin.cluster.node.tasks.get.GetTaskActio
|
|||
import static org.elasticsearch.action.admin.cluster.node.tasks.list.TransportListTasksAction.waitForCompletionTimeout;
|
||||
|
||||
/**
|
||||
* Action to get a single task. If the task isn't running then it'll try to request the status from request index.
|
||||
* ActionType to get a single task. If the task isn't running then it'll try to request the status from request index.
|
||||
*
|
||||
* The general flow is:
|
||||
* <ul>
|
||||
|
|
|
|||
|
|
@ -19,13 +19,13 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.node.tasks.list;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
/**
|
||||
* Action for retrieving a list of currently running tasks
|
||||
* ActionType for retrieving a list of currently running tasks
|
||||
*/
|
||||
public class ListTasksAction extends Action<ListTasksResponse> {
|
||||
public class ListTasksAction extends ActionType<ListTasksResponse> {
|
||||
|
||||
public static final ListTasksAction INSTANCE = new ListTasksAction();
|
||||
public static final String NAME = "cluster:monitor/tasks/lists";
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.node.usage;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class NodesUsageAction extends StreamableResponseAction<NodesUsageResponse> {
|
||||
public class NodesUsageAction extends StreamableResponseActionType<NodesUsageResponse> {
|
||||
|
||||
public static final NodesUsageAction INSTANCE = new NodesUsageAction();
|
||||
public static final String NAME = "cluster:monitor/nodes/usage";
|
||||
|
|
|
|||
|
|
@ -19,14 +19,14 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.node.usage;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.support.nodes.NodesOperationRequestBuilder;
|
||||
import org.elasticsearch.client.ElasticsearchClient;
|
||||
|
||||
public class NodesUsageRequestBuilder
|
||||
extends NodesOperationRequestBuilder<NodesUsageRequest, NodesUsageResponse, NodesUsageRequestBuilder> {
|
||||
|
||||
public NodesUsageRequestBuilder(ElasticsearchClient client, Action<NodesUsageResponse> action) {
|
||||
public NodesUsageRequestBuilder(ElasticsearchClient client, ActionType<NodesUsageResponse> action) {
|
||||
super(client, action, new NodesUsageRequest());
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.remote;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public final class RemoteInfoAction extends StreamableResponseAction<RemoteInfoResponse> {
|
||||
public final class RemoteInfoAction extends StreamableResponseActionType<RemoteInfoResponse> {
|
||||
|
||||
public static final String NAME = "cluster:monitor/remote/info";
|
||||
public static final RemoteInfoAction INSTANCE = new RemoteInfoAction();
|
||||
|
|
|
|||
|
|
@ -19,14 +19,14 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.repositories.delete;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.support.master.AcknowledgedResponse;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
/**
|
||||
* Unregister repository action
|
||||
*/
|
||||
public class DeleteRepositoryAction extends Action<AcknowledgedResponse> {
|
||||
public class DeleteRepositoryAction extends ActionType<AcknowledgedResponse> {
|
||||
|
||||
public static final DeleteRepositoryAction INSTANCE = new DeleteRepositoryAction();
|
||||
public static final String NAME = "cluster:admin/repository/delete";
|
||||
|
|
|
|||
|
|
@ -19,12 +19,12 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.repositories.get;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
/**
|
||||
* Get repositories action
|
||||
*/
|
||||
public class GetRepositoriesAction extends StreamableResponseAction<GetRepositoriesResponse> {
|
||||
public class GetRepositoriesAction extends StreamableResponseActionType<GetRepositoriesResponse> {
|
||||
|
||||
public static final GetRepositoriesAction INSTANCE = new GetRepositoriesAction();
|
||||
public static final String NAME = "cluster:admin/repository/get";
|
||||
|
|
|
|||
|
|
@ -19,14 +19,14 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.repositories.put;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.support.master.AcknowledgedResponse;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
/**
|
||||
* Register repository action
|
||||
*/
|
||||
public class PutRepositoryAction extends Action<AcknowledgedResponse> {
|
||||
public class PutRepositoryAction extends ActionType<AcknowledgedResponse> {
|
||||
|
||||
public static final PutRepositoryAction INSTANCE = new PutRepositoryAction();
|
||||
public static final String NAME = "cluster:admin/repository/put";
|
||||
|
|
|
|||
|
|
@ -19,12 +19,12 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.repositories.verify;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
/**
|
||||
* Unregister repository action
|
||||
*/
|
||||
public class VerifyRepositoryAction extends StreamableResponseAction<VerifyRepositoryResponse> {
|
||||
public class VerifyRepositoryAction extends StreamableResponseActionType<VerifyRepositoryResponse> {
|
||||
|
||||
public static final VerifyRepositoryAction INSTANCE = new VerifyRepositoryAction();
|
||||
public static final String NAME = "cluster:admin/repository/verify";
|
||||
|
|
|
|||
|
|
@ -19,10 +19,10 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.reroute;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
public class ClusterRerouteAction extends Action<ClusterRerouteResponse> {
|
||||
public class ClusterRerouteAction extends ActionType<ClusterRerouteResponse> {
|
||||
|
||||
public static final ClusterRerouteAction INSTANCE = new ClusterRerouteAction();
|
||||
public static final String NAME = "cluster:admin/reroute";
|
||||
|
|
|
|||
|
|
@ -19,10 +19,10 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.settings;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
public class ClusterUpdateSettingsAction extends Action<ClusterUpdateSettingsResponse> {
|
||||
public class ClusterUpdateSettingsAction extends ActionType<ClusterUpdateSettingsResponse> {
|
||||
|
||||
public static final ClusterUpdateSettingsAction INSTANCE = new ClusterUpdateSettingsAction();
|
||||
public static final String NAME = "cluster:admin/settings/update";
|
||||
|
|
|
|||
|
|
@ -19,10 +19,10 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.shards;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
public class ClusterSearchShardsAction extends Action<ClusterSearchShardsResponse> {
|
||||
public class ClusterSearchShardsAction extends ActionType<ClusterSearchShardsResponse> {
|
||||
|
||||
public static final ClusterSearchShardsAction INSTANCE = new ClusterSearchShardsAction();
|
||||
public static final String NAME = "indices:admin/shards/search_shards";
|
||||
|
|
|
|||
|
|
@ -19,12 +19,12 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.snapshots.create;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
/**
|
||||
* Create snapshot action
|
||||
*/
|
||||
public class CreateSnapshotAction extends StreamableResponseAction<CreateSnapshotResponse> {
|
||||
public class CreateSnapshotAction extends StreamableResponseActionType<CreateSnapshotResponse> {
|
||||
|
||||
public static final CreateSnapshotAction INSTANCE = new CreateSnapshotAction();
|
||||
public static final String NAME = "cluster:admin/snapshot/create";
|
||||
|
|
|
|||
|
|
@ -19,14 +19,14 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.snapshots.delete;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.support.master.AcknowledgedResponse;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
/**
|
||||
* Delete snapshot action
|
||||
*/
|
||||
public class DeleteSnapshotAction extends Action<AcknowledgedResponse> {
|
||||
public class DeleteSnapshotAction extends ActionType<AcknowledgedResponse> {
|
||||
|
||||
public static final DeleteSnapshotAction INSTANCE = new DeleteSnapshotAction();
|
||||
public static final String NAME = "cluster:admin/snapshot/delete";
|
||||
|
|
|
|||
|
|
@ -19,12 +19,12 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.snapshots.get;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
/**
|
||||
* Get snapshots action
|
||||
*/
|
||||
public class GetSnapshotsAction extends StreamableResponseAction<GetSnapshotsResponse> {
|
||||
public class GetSnapshotsAction extends StreamableResponseActionType<GetSnapshotsResponse> {
|
||||
|
||||
public static final GetSnapshotsAction INSTANCE = new GetSnapshotsAction();
|
||||
public static final String NAME = "cluster:admin/snapshot/get";
|
||||
|
|
|
|||
|
|
@ -19,12 +19,12 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.snapshots.restore;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
/**
|
||||
* Restore snapshot action
|
||||
*/
|
||||
public class RestoreSnapshotAction extends StreamableResponseAction<RestoreSnapshotResponse> {
|
||||
public class RestoreSnapshotAction extends StreamableResponseActionType<RestoreSnapshotResponse> {
|
||||
|
||||
public static final RestoreSnapshotAction INSTANCE = new RestoreSnapshotAction();
|
||||
public static final String NAME = "cluster:admin/snapshot/restore";
|
||||
|
|
|
|||
|
|
@ -19,12 +19,12 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.snapshots.status;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
/**
|
||||
* Snapshots status action
|
||||
*/
|
||||
public class SnapshotsStatusAction extends StreamableResponseAction<SnapshotsStatusResponse> {
|
||||
public class SnapshotsStatusAction extends StreamableResponseActionType<SnapshotsStatusResponse> {
|
||||
|
||||
public static final SnapshotsStatusAction INSTANCE = new SnapshotsStatusAction();
|
||||
public static final String NAME = "cluster:admin/snapshot/status";
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.state;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class ClusterStateAction extends StreamableResponseAction<ClusterStateResponse> {
|
||||
public class ClusterStateAction extends StreamableResponseActionType<ClusterStateResponse> {
|
||||
|
||||
public static final ClusterStateAction INSTANCE = new ClusterStateAction();
|
||||
public static final String NAME = "cluster:monitor/state";
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.stats;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class ClusterStatsAction extends StreamableResponseAction<ClusterStatsResponse> {
|
||||
public class ClusterStatsAction extends StreamableResponseActionType<ClusterStatsResponse> {
|
||||
|
||||
public static final ClusterStatsAction INSTANCE = new ClusterStatsAction();
|
||||
public static final String NAME = "cluster:monitor/stats";
|
||||
|
|
|
|||
|
|
@ -19,11 +19,11 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.storedscripts;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.support.master.AcknowledgedResponse;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
public class DeleteStoredScriptAction extends Action<AcknowledgedResponse> {
|
||||
public class DeleteStoredScriptAction extends ActionType<AcknowledgedResponse> {
|
||||
|
||||
public static final DeleteStoredScriptAction INSTANCE = new DeleteStoredScriptAction();
|
||||
public static final String NAME = "cluster:admin/script/delete";
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.storedscripts;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class GetStoredScriptAction extends StreamableResponseAction<GetStoredScriptResponse> {
|
||||
public class GetStoredScriptAction extends StreamableResponseActionType<GetStoredScriptResponse> {
|
||||
|
||||
public static final GetStoredScriptAction INSTANCE = new GetStoredScriptAction();
|
||||
public static final String NAME = "cluster:admin/script/get";
|
||||
|
|
|
|||
|
|
@ -19,12 +19,12 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.storedscripts;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.support.master.AcknowledgedResponse;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
|
||||
public class PutStoredScriptAction extends Action<AcknowledgedResponse> {
|
||||
public class PutStoredScriptAction extends ActionType<AcknowledgedResponse> {
|
||||
|
||||
public static final PutStoredScriptAction INSTANCE = new PutStoredScriptAction();
|
||||
public static final String NAME = "cluster:admin/script/put";
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.cluster.tasks;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class PendingClusterTasksAction extends StreamableResponseAction<PendingClusterTasksResponse> {
|
||||
public class PendingClusterTasksAction extends StreamableResponseActionType<PendingClusterTasksResponse> {
|
||||
|
||||
public static final PendingClusterTasksAction INSTANCE = new PendingClusterTasksAction();
|
||||
public static final String NAME = "cluster:monitor/task";
|
||||
|
|
|
|||
|
|
@ -19,11 +19,11 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.alias;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.support.master.AcknowledgedResponse;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
public class IndicesAliasesAction extends Action<AcknowledgedResponse> {
|
||||
public class IndicesAliasesAction extends ActionType<AcknowledgedResponse> {
|
||||
|
||||
public static final IndicesAliasesAction INSTANCE = new IndicesAliasesAction();
|
||||
public static final String NAME = "indices:admin/aliases";
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.alias.exists;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class AliasesExistAction extends StreamableResponseAction<AliasesExistResponse> {
|
||||
public class AliasesExistAction extends StreamableResponseActionType<AliasesExistResponse> {
|
||||
|
||||
public static final AliasesExistAction INSTANCE = new AliasesExistAction();
|
||||
public static final String NAME = "indices:admin/aliases/exists";
|
||||
|
|
|
|||
|
|
@ -19,7 +19,7 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.alias.get;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.ActionResponse;
|
||||
import org.elasticsearch.action.support.IndicesOptions;
|
||||
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
|
||||
|
|
@ -30,7 +30,7 @@ public abstract class BaseAliasesRequestBuilder<Response extends ActionResponse,
|
|||
Builder extends BaseAliasesRequestBuilder<Response, Builder>>
|
||||
extends MasterNodeReadOperationRequestBuilder<GetAliasesRequest, Response, Builder> {
|
||||
|
||||
public BaseAliasesRequestBuilder(ElasticsearchClient client, Action<Response> action, String... aliases) {
|
||||
public BaseAliasesRequestBuilder(ElasticsearchClient client, ActionType<Response> action, String... aliases) {
|
||||
super(client, action, new GetAliasesRequest(aliases));
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.alias.get;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class GetAliasesAction extends StreamableResponseAction<GetAliasesResponse> {
|
||||
public class GetAliasesAction extends StreamableResponseActionType<GetAliasesResponse> {
|
||||
|
||||
public static final GetAliasesAction INSTANCE = new GetAliasesAction();
|
||||
public static final String NAME = "indices:admin/aliases/get";
|
||||
|
|
|
|||
|
|
@ -19,7 +19,7 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.analyze;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.ActionRequestValidationException;
|
||||
import org.elasticsearch.action.ActionResponse;
|
||||
import org.elasticsearch.action.support.single.shard.SingleShardRequest;
|
||||
|
|
@ -45,7 +45,7 @@ import java.util.TreeMap;
|
|||
|
||||
import static org.elasticsearch.action.ValidateActions.addValidationError;
|
||||
|
||||
public class AnalyzeAction extends Action<AnalyzeAction.Response> {
|
||||
public class AnalyzeAction extends ActionType<AnalyzeAction.Response> {
|
||||
|
||||
public static final AnalyzeAction INSTANCE = new AnalyzeAction();
|
||||
public static final String NAME = "indices:admin/analyze";
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.cache.clear;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class ClearIndicesCacheAction extends StreamableResponseAction<ClearIndicesCacheResponse> {
|
||||
public class ClearIndicesCacheAction extends StreamableResponseActionType<ClearIndicesCacheResponse> {
|
||||
|
||||
public static final ClearIndicesCacheAction INSTANCE = new ClearIndicesCacheAction();
|
||||
public static final String NAME = "indices:admin/cache/clear";
|
||||
|
|
|
|||
|
|
@ -19,10 +19,10 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.close;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
public class CloseIndexAction extends Action<CloseIndexResponse> {
|
||||
public class CloseIndexAction extends ActionType<CloseIndexResponse> {
|
||||
|
||||
public static final CloseIndexAction INSTANCE = new CloseIndexAction();
|
||||
public static final String NAME = "indices:admin/close";
|
||||
|
|
|
|||
|
|
@ -19,10 +19,10 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.create;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
public class CreateIndexAction extends Action<CreateIndexResponse> {
|
||||
public class CreateIndexAction extends ActionType<CreateIndexResponse> {
|
||||
|
||||
public static final CreateIndexAction INSTANCE = new CreateIndexAction();
|
||||
public static final String NAME = "indices:admin/create";
|
||||
|
|
|
|||
|
|
@ -19,11 +19,11 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.delete;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.support.master.AcknowledgedResponse;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
public class DeleteIndexAction extends Action<AcknowledgedResponse> {
|
||||
public class DeleteIndexAction extends ActionType<AcknowledgedResponse> {
|
||||
|
||||
public static final DeleteIndexAction INSTANCE = new DeleteIndexAction();
|
||||
public static final String NAME = "indices:admin/delete";
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.exists.indices;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class IndicesExistsAction extends StreamableResponseAction<IndicesExistsResponse> {
|
||||
public class IndicesExistsAction extends StreamableResponseActionType<IndicesExistsResponse> {
|
||||
|
||||
public static final IndicesExistsAction INSTANCE = new IndicesExistsAction();
|
||||
public static final String NAME = "indices:admin/exists";
|
||||
|
|
|
|||
|
|
@ -18,9 +18,9 @@
|
|||
*/
|
||||
package org.elasticsearch.action.admin.indices.exists.types;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class TypesExistsAction extends StreamableResponseAction<TypesExistsResponse> {
|
||||
public class TypesExistsAction extends StreamableResponseActionType<TypesExistsResponse> {
|
||||
|
||||
public static final TypesExistsAction INSTANCE = new TypesExistsAction();
|
||||
public static final String NAME = "indices:admin/types/exists";
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.flush;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class FlushAction extends StreamableResponseAction<FlushResponse> {
|
||||
public class FlushAction extends StreamableResponseActionType<FlushResponse> {
|
||||
|
||||
public static final FlushAction INSTANCE = new FlushAction();
|
||||
public static final String NAME = "indices:admin/flush";
|
||||
|
|
|
|||
|
|
@ -19,10 +19,10 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.flush;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
|
||||
public class SyncedFlushAction extends StreamableResponseAction<SyncedFlushResponse> {
|
||||
public class SyncedFlushAction extends StreamableResponseActionType<SyncedFlushResponse> {
|
||||
|
||||
public static final SyncedFlushAction INSTANCE = new SyncedFlushAction();
|
||||
public static final String NAME = "indices:admin/synced_flush";
|
||||
|
|
|
|||
|
|
@ -32,7 +32,7 @@ import org.elasticsearch.transport.TransportService;
|
|||
import java.util.List;
|
||||
|
||||
/**
|
||||
* Flush Action.
|
||||
* Flush ActionType.
|
||||
*/
|
||||
public class TransportFlushAction
|
||||
extends TransportBroadcastReplicationAction<FlushRequest, FlushResponse, ShardFlushRequest, ReplicationResponse> {
|
||||
|
|
|
|||
|
|
@ -30,7 +30,7 @@ import org.elasticsearch.transport.TransportService;
|
|||
import java.util.function.Supplier;
|
||||
|
||||
/**
|
||||
* Synced flush Action.
|
||||
* Synced flush ActionType.
|
||||
*/
|
||||
public class TransportSyncedFlushAction extends HandledTransportAction<SyncedFlushRequest, SyncedFlushResponse> {
|
||||
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.forcemerge;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class ForceMergeAction extends StreamableResponseAction<ForceMergeResponse> {
|
||||
public class ForceMergeAction extends StreamableResponseActionType<ForceMergeResponse> {
|
||||
|
||||
public static final ForceMergeAction INSTANCE = new ForceMergeAction();
|
||||
public static final String NAME = "indices:admin/forcemerge";
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.get;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class GetIndexAction extends StreamableResponseAction<GetIndexResponse> {
|
||||
public class GetIndexAction extends StreamableResponseActionType<GetIndexResponse> {
|
||||
|
||||
public static final GetIndexAction INSTANCE = new GetIndexAction();
|
||||
public static final String NAME = "indices:admin/get";
|
||||
|
|
|
|||
|
|
@ -19,10 +19,10 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.mapping.get;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
public class GetFieldMappingsAction extends Action<GetFieldMappingsResponse> {
|
||||
public class GetFieldMappingsAction extends ActionType<GetFieldMappingsResponse> {
|
||||
|
||||
public static final GetFieldMappingsAction INSTANCE = new GetFieldMappingsAction();
|
||||
public static final String NAME = "indices:admin/mappings/fields/get";
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.mapping.get;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class GetMappingsAction extends StreamableResponseAction<GetMappingsResponse> {
|
||||
public class GetMappingsAction extends StreamableResponseActionType<GetMappingsResponse> {
|
||||
|
||||
public static final GetMappingsAction INSTANCE = new GetMappingsAction();
|
||||
public static final String NAME = "indices:admin/mappings/get";
|
||||
|
|
|
|||
|
|
@ -19,11 +19,11 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.mapping.put;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.support.master.AcknowledgedResponse;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
public class PutMappingAction extends Action<AcknowledgedResponse> {
|
||||
public class PutMappingAction extends ActionType<AcknowledgedResponse> {
|
||||
|
||||
public static final PutMappingAction INSTANCE = new PutMappingAction();
|
||||
public static final String NAME = "indices:admin/mapping/put";
|
||||
|
|
|
|||
|
|
@ -19,10 +19,10 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.open;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
public class OpenIndexAction extends Action<OpenIndexResponse> {
|
||||
public class OpenIndexAction extends ActionType<OpenIndexResponse> {
|
||||
|
||||
public static final OpenIndexAction INSTANCE = new OpenIndexAction();
|
||||
public static final String NAME = "indices:admin/open";
|
||||
|
|
|
|||
|
|
@ -19,12 +19,12 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.recovery;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
/**
|
||||
* Recovery information action
|
||||
*/
|
||||
public class RecoveryAction extends StreamableResponseAction<RecoveryResponse> {
|
||||
public class RecoveryAction extends StreamableResponseActionType<RecoveryResponse> {
|
||||
|
||||
public static final RecoveryAction INSTANCE = new RecoveryAction();
|
||||
public static final String NAME = "indices:monitor/recovery";
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.refresh;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class RefreshAction extends StreamableResponseAction<RefreshResponse> {
|
||||
public class RefreshAction extends StreamableResponseActionType<RefreshResponse> {
|
||||
|
||||
public static final RefreshAction INSTANCE = new RefreshAction();
|
||||
public static final String NAME = "indices:admin/refresh";
|
||||
|
|
|
|||
|
|
@ -19,10 +19,10 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.rollover;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
public class RolloverAction extends Action<RolloverResponse> {
|
||||
public class RolloverAction extends ActionType<RolloverResponse> {
|
||||
|
||||
public static final RolloverAction INSTANCE = new RolloverAction();
|
||||
public static final String NAME = "indices:admin/rollover";
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.segments;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class IndicesSegmentsAction extends StreamableResponseAction<IndicesSegmentResponse> {
|
||||
public class IndicesSegmentsAction extends StreamableResponseActionType<IndicesSegmentResponse> {
|
||||
|
||||
public static final IndicesSegmentsAction INSTANCE = new IndicesSegmentsAction();
|
||||
public static final String NAME = "indices:monitor/segments";
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.settings.get;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class GetSettingsAction extends StreamableResponseAction<GetSettingsResponse> {
|
||||
public class GetSettingsAction extends StreamableResponseActionType<GetSettingsResponse> {
|
||||
|
||||
public static final GetSettingsAction INSTANCE = new GetSettingsAction();
|
||||
public static final String NAME = "indices:monitor/settings/get";
|
||||
|
|
|
|||
|
|
@ -19,11 +19,11 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.settings.put;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.support.master.AcknowledgedResponse;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
public class UpdateSettingsAction extends Action<AcknowledgedResponse> {
|
||||
public class UpdateSettingsAction extends ActionType<AcknowledgedResponse> {
|
||||
|
||||
public static final UpdateSettingsAction INSTANCE = new UpdateSettingsAction();
|
||||
public static final String NAME = "indices:admin/settings/update";
|
||||
|
|
|
|||
|
|
@ -19,7 +19,7 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.shards;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.support.IndicesOptions;
|
||||
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
|
||||
import org.elasticsearch.client.ElasticsearchClient;
|
||||
|
|
@ -33,7 +33,7 @@ public class IndicesShardStoreRequestBuilder extends MasterNodeReadOperationRequ
|
|||
IndicesShardStoresResponse,
|
||||
IndicesShardStoreRequestBuilder> {
|
||||
|
||||
public IndicesShardStoreRequestBuilder(ElasticsearchClient client, Action<IndicesShardStoresResponse> action, String... indices) {
|
||||
public IndicesShardStoreRequestBuilder(ElasticsearchClient client, ActionType<IndicesShardStoresResponse> action, String... indices) {
|
||||
super(client, action, new IndicesShardStoresRequest(indices));
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -19,16 +19,16 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.shards;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
/**
|
||||
* Action for {@link TransportIndicesShardStoresAction}
|
||||
* ActionType for {@link TransportIndicesShardStoresAction}
|
||||
*
|
||||
* Exposes shard store information for requested indices.
|
||||
* Shard store information reports which nodes hold shard copies, how recent they are
|
||||
* and any exceptions on opening the shard index or from previous engine failures
|
||||
*/
|
||||
public class IndicesShardStoresAction extends StreamableResponseAction<IndicesShardStoresResponse> {
|
||||
public class IndicesShardStoresAction extends StreamableResponseActionType<IndicesShardStoresResponse> {
|
||||
|
||||
public static final IndicesShardStoresAction INSTANCE = new IndicesShardStoresAction();
|
||||
public static final String NAME = "indices:monitor/shard_stores";
|
||||
|
|
|
|||
|
|
@ -20,10 +20,10 @@
|
|||
package org.elasticsearch.action.admin.indices.shrink;
|
||||
|
||||
import org.elasticsearch.Version;
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
public class ResizeAction extends Action<ResizeResponse> {
|
||||
public class ResizeAction extends ActionType<ResizeResponse> {
|
||||
|
||||
public static final ResizeAction INSTANCE = new ResizeAction();
|
||||
public static final String NAME = "indices:admin/resize";
|
||||
|
|
|
|||
|
|
@ -18,7 +18,7 @@
|
|||
*/
|
||||
package org.elasticsearch.action.admin.indices.shrink;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.admin.indices.create.CreateIndexRequest;
|
||||
import org.elasticsearch.action.support.ActiveShardCount;
|
||||
import org.elasticsearch.action.support.master.AcknowledgedRequestBuilder;
|
||||
|
|
@ -27,7 +27,7 @@ import org.elasticsearch.common.settings.Settings;
|
|||
|
||||
public class ResizeRequestBuilder extends AcknowledgedRequestBuilder<ResizeRequest, ResizeResponse,
|
||||
ResizeRequestBuilder> {
|
||||
public ResizeRequestBuilder(ElasticsearchClient client, Action<ResizeResponse> action) {
|
||||
public ResizeRequestBuilder(ElasticsearchClient client, ActionType<ResizeResponse> action) {
|
||||
super(client, action, new ResizeRequest());
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -19,10 +19,10 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.shrink;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
public class ShrinkAction extends Action<ResizeResponse> {
|
||||
public class ShrinkAction extends ActionType<ResizeResponse> {
|
||||
|
||||
public static final ShrinkAction INSTANCE = new ShrinkAction();
|
||||
public static final String NAME = "indices:admin/shrink";
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.stats;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class IndicesStatsAction extends StreamableResponseAction<IndicesStatsResponse> {
|
||||
public class IndicesStatsAction extends StreamableResponseActionType<IndicesStatsResponse> {
|
||||
|
||||
public static final IndicesStatsAction INSTANCE = new IndicesStatsAction();
|
||||
public static final String NAME = "indices:monitor/stats";
|
||||
|
|
|
|||
|
|
@ -19,11 +19,11 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.template.delete;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.support.master.AcknowledgedResponse;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
public class DeleteIndexTemplateAction extends Action<AcknowledgedResponse> {
|
||||
public class DeleteIndexTemplateAction extends ActionType<AcknowledgedResponse> {
|
||||
|
||||
public static final DeleteIndexTemplateAction INSTANCE = new DeleteIndexTemplateAction();
|
||||
public static final String NAME = "indices:admin/template/delete";
|
||||
|
|
|
|||
|
|
@ -18,9 +18,9 @@
|
|||
*/
|
||||
package org.elasticsearch.action.admin.indices.template.get;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class GetIndexTemplatesAction extends StreamableResponseAction<GetIndexTemplatesResponse> {
|
||||
public class GetIndexTemplatesAction extends StreamableResponseActionType<GetIndexTemplatesResponse> {
|
||||
|
||||
public static final GetIndexTemplatesAction INSTANCE = new GetIndexTemplatesAction();
|
||||
public static final String NAME = "indices:admin/template/get";
|
||||
|
|
|
|||
|
|
@ -19,11 +19,11 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.template.put;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.support.master.AcknowledgedResponse;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
public class PutIndexTemplateAction extends Action<AcknowledgedResponse> {
|
||||
public class PutIndexTemplateAction extends ActionType<AcknowledgedResponse> {
|
||||
|
||||
public static final PutIndexTemplateAction INSTANCE = new PutIndexTemplateAction();
|
||||
public static final String NAME = "indices:admin/template/put";
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.upgrade.get;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class UpgradeStatusAction extends StreamableResponseAction<UpgradeStatusResponse> {
|
||||
public class UpgradeStatusAction extends StreamableResponseActionType<UpgradeStatusResponse> {
|
||||
|
||||
public static final UpgradeStatusAction INSTANCE = new UpgradeStatusAction();
|
||||
public static final String NAME = "indices:monitor/upgrade";
|
||||
|
|
|
|||
|
|
@ -19,12 +19,12 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.upgrade.post;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
/**
|
||||
* Upgrade index/indices action.
|
||||
*/
|
||||
public class UpgradeAction extends StreamableResponseAction<UpgradeResponse> {
|
||||
public class UpgradeAction extends StreamableResponseActionType<UpgradeResponse> {
|
||||
|
||||
public static final UpgradeAction INSTANCE = new UpgradeAction();
|
||||
public static final String NAME = "indices:admin/upgrade";
|
||||
|
|
|
|||
|
|
@ -19,11 +19,11 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.upgrade.post;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.action.support.master.AcknowledgedResponse;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
public class UpgradeSettingsAction extends Action<AcknowledgedResponse> {
|
||||
public class UpgradeSettingsAction extends ActionType<AcknowledgedResponse> {
|
||||
|
||||
public static final UpgradeSettingsAction INSTANCE = new UpgradeSettingsAction();
|
||||
public static final String NAME = "internal:indices/admin/upgrade";
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.admin.indices.validate.query;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class ValidateQueryAction extends StreamableResponseAction<ValidateQueryResponse> {
|
||||
public class ValidateQueryAction extends StreamableResponseActionType<ValidateQueryResponse> {
|
||||
|
||||
public static final ValidateQueryAction INSTANCE = new ValidateQueryAction();
|
||||
public static final String NAME = "indices:admin/validate/query";
|
||||
|
|
|
|||
|
|
@ -19,11 +19,11 @@
|
|||
|
||||
package org.elasticsearch.action.bulk;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.transport.TransportRequestOptions;
|
||||
|
||||
public class BulkAction extends StreamableResponseAction<BulkResponse> {
|
||||
public class BulkAction extends StreamableResponseActionType<BulkResponse> {
|
||||
|
||||
public static final BulkAction INSTANCE = new BulkAction();
|
||||
public static final String NAME = "indices:data/write/bulk";
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.delete;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class DeleteAction extends StreamableResponseAction<DeleteResponse> {
|
||||
public class DeleteAction extends StreamableResponseActionType<DeleteResponse> {
|
||||
|
||||
public static final DeleteAction INSTANCE = new DeleteAction();
|
||||
public static final String NAME = "indices:data/write/delete";
|
||||
|
|
|
|||
|
|
@ -19,13 +19,13 @@
|
|||
|
||||
package org.elasticsearch.action.explain;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
/**
|
||||
* Entry point for the explain feature.
|
||||
*/
|
||||
public class ExplainAction extends Action<ExplainResponse> {
|
||||
public class ExplainAction extends ActionType<ExplainResponse> {
|
||||
|
||||
public static final ExplainAction INSTANCE = new ExplainAction();
|
||||
public static final String NAME = "indices:data/read/explain";
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.fieldcaps;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class FieldCapabilitiesAction extends StreamableResponseAction<FieldCapabilitiesResponse> {
|
||||
public class FieldCapabilitiesAction extends StreamableResponseActionType<FieldCapabilitiesResponse> {
|
||||
|
||||
public static final FieldCapabilitiesAction INSTANCE = new FieldCapabilitiesAction();
|
||||
public static final String NAME = "indices:data/read/field_caps";
|
||||
|
|
|
|||
|
|
@ -19,10 +19,10 @@
|
|||
|
||||
package org.elasticsearch.action.get;
|
||||
|
||||
import org.elasticsearch.action.Action;
|
||||
import org.elasticsearch.action.ActionType;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
||||
public class GetAction extends Action<GetResponse> {
|
||||
public class GetAction extends ActionType<GetResponse> {
|
||||
|
||||
public static final GetAction INSTANCE = new GetAction();
|
||||
public static final String NAME = "indices:data/read/get";
|
||||
|
|
|
|||
|
|
@ -19,9 +19,9 @@
|
|||
|
||||
package org.elasticsearch.action.get;
|
||||
|
||||
import org.elasticsearch.action.StreamableResponseAction;
|
||||
import org.elasticsearch.action.StreamableResponseActionType;
|
||||
|
||||
public class MultiGetAction extends StreamableResponseAction<MultiGetResponse> {
|
||||
public class MultiGetAction extends StreamableResponseActionType<MultiGetResponse> {
|
||||
|
||||
public static final MultiGetAction INSTANCE = new MultiGetAction();
|
||||
public static final String NAME = "indices:data/read/mget";
|
||||
|
|
|
|||
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in New Issue