opensearch-project · kartg · May 13, 2022 · May 6, 2022
@@ -47,6 +47,11 @@
 
 import static java.util.stream.Collectors.toSet;
 
+/**
+ * Base REST channel
+ *
+ * @opensearch.api
+ */
 public abstract class AbstractRestChannel implements RestChannel {
 
     private static final Predicate<String> INCLUDE_FILTER = f -> f.charAt(0) != '-';

@@ -66,6 +66,8 @@
  * the transport requests executed by the associated client. While the context is fully copied over, not all the headers
  * are copied, but a selected few. It is possible to control what headers are copied over by returning them in
  * {@link ActionPlugin#getRestHeaders()}.
+ *
+ * @opensearch.api
  */
 public abstract class BaseRestHandler implements RestHandler {
 

@@ -52,6 +52,11 @@
 import static org.opensearch.OpenSearchException.REST_EXCEPTION_SKIP_STACK_TRACE_DEFAULT;
 import static org.opensearch.common.xcontent.XContentParserUtils.ensureExpectedToken;
 
+/**
+ * REST response in bytes
+ *
+ * @opensearch.api
+ */
 public class BytesRestResponse extends RestResponse {
 
     public static final String TEXT_CONTENT_TYPE = "text/plain; charset=UTF-8";

@@ -40,6 +40,8 @@
 /**
  * {@code DeprecationRestHandler} provides a proxy for any existing {@link RestHandler} so that usage of the handler can be
  * logged using the {@link DeprecationLogger}.
+ *
+ * @opensearch.api
  */
 public class DeprecationRestHandler implements RestHandler {
 

@@ -40,6 +40,8 @@
 
 /**
  * Encapsulate multiple handlers for the same path, allowing different handlers for different HTTP verbs.
+ *
+ * @opensearch.api
  */
 final class MethodHandlers {
 

@@ -41,6 +41,8 @@
 
 /**
  * A channel used to construct bytes / builder based outputs, and send responses.
+ *
+ * @opensearch.api
  */
 public interface RestChannel {
 

@@ -75,6 +75,11 @@
 import static org.opensearch.rest.RestStatus.NOT_ACCEPTABLE;
 import static org.opensearch.rest.RestStatus.OK;
 
+/**
+ * OpenSearch REST controller
+ *
+ * @opensearch.api
+ */
 public class RestController implements HttpServerTransport.Dispatcher {
 
     private static final Logger logger = LogManager.getLogger(RestController.class);

@@ -43,6 +43,8 @@
 
 /**
  * Handler for REST requests
+ *
+ * @opensearch.api
  */
 @FunctionalInterface
 public interface RestHandler {

@@ -35,6 +35,8 @@
 /**
  * A definition for an http header that should be copied to the {@link org.opensearch.common.util.concurrent.ThreadContext} when
  * reading the request on the rest layer.
+ *
+ * @opensearch.api
  */
 public final class RestHeaderDefinition {
     private final String name;

@@ -67,6 +67,11 @@
 import static org.opensearch.common.unit.ByteSizeValue.parseBytesSizeValue;
 import static org.opensearch.common.unit.TimeValue.parseTimeValue;
 
+/**
+ * REST Request
+ *
+ * @opensearch.api
+ */
 public class RestRequest implements ToXContent.Params {
 
     // tchar pattern as defined by RFC7230 section 3.2.6

@@ -48,6 +48,8 @@
 /**
  * Identifies an object that supplies a filter for the content of a {@link RestRequest}. This interface should be implemented by a
  * {@link org.opensearch.rest.RestHandler} that expects there will be sensitive content in the body of the request such as a password
+ *
+ * @opensearch.api
  */
 public interface RestRequestFilter {
 

@@ -42,6 +42,11 @@
 import java.util.Map;
 import java.util.Set;
 
+/**
+ * OpenSearch REST response
+ *
+ * @opensearch.api
+ */
 public abstract class RestResponse {
 
     private Map<String, List<String>> customHeaders;

@@ -42,6 +42,11 @@
 
 import static java.util.Collections.unmodifiableMap;
 
+/**
+ * OpenSearch REST status
+ *
+ * @opensearch.api
+ */
 public enum RestStatus {
     /**
      * The client SHOULD continue with its request. This interim response is used to inform the client that the

@@ -42,6 +42,11 @@
 import java.util.Map;
 import java.util.regex.Pattern;
 
+/**
+ * REST utility class
+ *
+ * @opensearch.api
+ */
 public class RestUtils {
 
     /**

@@ -43,6 +43,8 @@
 /**
  * An action listener that requires {@link #processResponse(Object)} to be implemented
  * and will automatically handle failures.
+ *
+ * @opensearch.api
  */
 public abstract class RestActionListener<Response> implements ActionListener<Response> {
 

@@ -61,6 +61,11 @@
 
 import static org.opensearch.index.query.AbstractQueryBuilder.parseInnerQueryBuilder;
 
+/**
+ * REST actions
+ *
+ * @opensearch.api
+ */
 public class RestActions {
 
     public static final ParseField _SHARDS_FIELD = new ParseField("_shards");

@@ -38,6 +38,8 @@
 
 /**
  * A REST action listener that builds an {@link XContentBuilder} based response.
+ *
+ * @opensearch.api
  */
 public abstract class RestBuilderListener<Response> extends RestResponseListener<Response> {
 

@@ -58,6 +58,8 @@
 /**
  * A {@linkplain Client} that cancels tasks executed locally when the provided {@link HttpChannel}
  * is closed before completion.
+ *
+ * @opensearch.api
  */
 public class RestCancellableNodeClient extends FilterClient {
     private static final Map<HttpChannel, CloseListener> httpChannels = new ConcurrentHashMap<>();

@@ -47,6 +47,11 @@
 import static org.opensearch.rest.RestRequest.Method.GET;
 import static org.opensearch.rest.RestRequest.Method.POST;
 
+/**
+ * Transport action to get field capabilities
+ *
+ * @opensearch.api
+ */
 public class RestFieldCapabilitiesAction extends BaseRestHandler {
 
     @Override

@@ -51,6 +51,11 @@
 import static org.opensearch.rest.RestRequest.Method.GET;
 import static org.opensearch.rest.RestRequest.Method.HEAD;
 
+/**
+ * Main OpenSearch Transport action
+ *
+ * @opensearch.api
+ */
 public class RestMainAction extends BaseRestHandler {
 
     @Override

@@ -38,6 +38,8 @@
 /**
  * A REST enabled action listener that has a basic onFailure implementation, and requires
  * sub classes to only implement {@link #buildResponse(Object)}.
+ *
+ * @opensearch.api
  */
 public abstract class RestResponseListener<Response> extends RestActionListener<Response> {
 

@@ -42,6 +42,8 @@
 
 /**
  * Content listener that extracts that {@link RestStatus} from the response.
+ *
+ * @opensearch.api
  */
 public class RestStatusToXContentListener<Response extends StatusToXContentObject> extends RestToXContentListener<Response> {
     private final Function<Response, String> extractLocation;

@@ -43,6 +43,8 @@
 /**
  * A REST based action listener that assumes the response is of type {@link ToXContent} and automatically
  * builds an XContent based response (wrapping the toXContent in startObject/endObject).
+ *
+ * @opensearch.api
  */
 public class RestToXContentListener<Response extends ToXContentObject> extends RestResponseListener<Response> {
 

@@ -49,6 +49,11 @@
 
 import static org.opensearch.rest.RestRequest.Method.POST;
 
+/**
+ * Transport action to add voting config exclusions
+ *
+ * @opensearch.api
+ */
 public class RestAddVotingConfigExclusionAction extends BaseRestHandler {
     private static final TimeValue DEFAULT_TIMEOUT = TimeValue.timeValueSeconds(30L);
     private static final Logger logger = LogManager.getLogger(RestAddVotingConfigExclusionAction.class);

@@ -49,6 +49,11 @@
 import static org.opensearch.rest.RestRequest.Method.POST;
 import static org.opensearch.rest.action.admin.cluster.RestListTasksAction.listTasksResponseListener;
 
+/**
+ * Transport action to cancel tasks
+ *
+ * @opensearch.api
+ */
 public class RestCancelTasksAction extends BaseRestHandler {
     private final Supplier<DiscoveryNodes> nodesInCluster;
 

@@ -48,6 +48,8 @@
 
 /**
  * Cleans up a repository
+ *
+ * @opensearch.api
  */
 public class RestCleanupRepositoryAction extends BaseRestHandler {
 

@@ -45,6 +45,11 @@
 import static java.util.Collections.singletonList;
 import static org.opensearch.rest.RestRequest.Method.DELETE;
 
+/**
+ * Transport action to clear voting config exclusions
+ *
+ * @opensearch.api
+ */
 public class RestClearVotingConfigExclusionsAction extends BaseRestHandler {
 
     @Override

@@ -50,6 +50,8 @@
 
 /**
  * Clones indices from one snapshot into another snapshot in the same repository
+ *
+ * @opensearch.api
  */
 public class RestCloneSnapshotAction extends BaseRestHandler {
 

@@ -55,6 +55,8 @@
 
 /**
  * Class handling cluster allocation explanation at the REST level
+ *
+ * @opensearch.api
  */
 public class RestClusterAllocationExplainAction extends BaseRestHandler {
 

@@ -58,6 +58,11 @@
 import static java.util.Collections.singletonList;
 import static org.opensearch.rest.RestRequest.Method.GET;
 
+/**
+ * Transport action to get settings
+ *
+ * @opensearch.api
+ */
 public class RestClusterGetSettingsAction extends BaseRestHandler {
 
     private static final DeprecationLogger deprecationLogger = DeprecationLogger.getLogger(RestClusterGetSettingsAction.class);

@@ -55,6 +55,11 @@
 import static org.opensearch.client.Requests.clusterHealthRequest;
 import static org.opensearch.rest.RestRequest.Method.GET;
 
+/**
+ * Transport action to get cluster health
+ *
+ * @opensearch.api
+ */
 public class RestClusterHealthAction extends BaseRestHandler {
 
     private static final DeprecationLogger deprecationLogger = DeprecationLogger.getLogger(RestClusterHealthAction.class);

@@ -58,6 +58,11 @@
 import static java.util.Collections.singletonList;
 import static org.opensearch.rest.RestRequest.Method.POST;
 
+/**
+ * Transport action to reroute documents
+ *
+ * @opensearch.api
+ */
 public class RestClusterRerouteAction extends BaseRestHandler {
     private static final ObjectParser<ClusterRerouteRequest, Void> PARSER = new ObjectParser<>("cluster_reroute");
     static {

@@ -49,6 +49,11 @@
 import static org.opensearch.rest.RestRequest.Method.GET;
 import static org.opensearch.rest.RestRequest.Method.POST;
 
+/**
+ * Transport action to search shards
+ *
+ * @opensearch.api
+ */
 public class RestClusterSearchShardsAction extends BaseRestHandler {
 
     @Override

@@ -64,6 +64,11 @@
 import static java.util.Collections.unmodifiableList;
 import static org.opensearch.rest.RestRequest.Method.GET;
 
+/**
+ * Transport action to get cluster state
+ *
+ * @opensearch.api
+ */
 public class RestClusterStateAction extends BaseRestHandler {
 
     private final SettingsFilter settingsFilter;

@@ -45,6 +45,11 @@
 import static java.util.Collections.unmodifiableList;
 import static org.opensearch.rest.RestRequest.Method.GET;
 
+/**
+ * Transport action to get cluster stats
+ *
+ * @opensearch.api
+ */
 public class RestClusterStatsAction extends BaseRestHandler {
 
     @Override

@@ -50,6 +50,11 @@
 import static java.util.Collections.singletonList;
 import static org.opensearch.rest.RestRequest.Method.PUT;
 
+/**
+ * Transport action to update cluster settings
+ *
+ * @opensearch.api
+ */
 public class RestClusterUpdateSettingsAction extends BaseRestHandler {
 
     private static final DeprecationLogger deprecationLogger = DeprecationLogger.getLogger(RestClusterUpdateSettingsAction.class);

@@ -50,6 +50,8 @@
 
 /**
  * Creates a new snapshot
+ *
+ * @opensearch.api
  */
 public class RestCreateSnapshotAction extends BaseRestHandler {
-Original file line number
+Diff line change
@@ Expand Up / @@ -40,6 +40,8 @@ @@
     /**
      * Encapsulate multiple handlers for the same path, allowing different handlers for different HTTP verbs.
+     *
+     * @opensearch.api
      */
     final class MethodHandlers {
@@ Expand Down @@