[API] Added the "Reindex" API

Related: elastic/elasticsearch#15201

Author: karmi

elasticsearch-api/lib/elasticsearch/api/actions/reindex.rb

@@ -0,0 +1,69 @@
+module Elasticsearch
+  module API
+    module Actions
+
+      # Copy documents from one index to another, potentially changing
+      # its settings, mappings and the documents itself.
+      #
+      # @example Copy documents into a different index
+      #
+      #     client.reindex body: { source: { index: 'test1' }, dest: { index: 'test2' } }
+      #
+      # @example Limit the copied documents with a query
+      #
+      #     client.reindex body: {
+      #       source: {
+      #         index: 'test1',
+      #         query: { terms: { category: ['one', 'two'] }  }
+      #       },
+      #       dest: {
+      #         index: 'test2'
+      #       }
+      #     }
+      #
+      # @example Remove a field from reindexed documents
+      #
+      #     client.reindex body: {
+      #       source: {
+      #         index: 'test1'
+      #       },
+      #       dest: {
+      #         index: 'test3'
+      #       },
+      #       script: {
+      #         inline: 'ctx._source.remove("category")'
+      #       }
+      #     }
+      #
+      # @option arguments [Hash] :body The definition of the operation (source index, target index, ...)
+      #                                (*Required*)
+      # @option arguments [Boolean] :refresh Whether the affected indexes should be refreshed
+      # @option arguments [Time] :timeout Time each individual bulk request should wait for shards
+      #                                   that are unavailable. (Default: 1m)
+      # @option arguments [String] :consistency Explicit write consistency setting for the operation
+      #                                        (Options: one, quorum, all)
+      # @option arguments [Boolean] :wait_for_completion Whether the request should block and wait until
+        #                                                the operation has completed
+      # @option arguments [Float] :requests_per_second The throttling for this request in sub-requests per second.
+      #                                                0 means set no throttling (default)
+      #
+      # @see https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-reindex.html
+      #
+      def reindex(arguments={})
+        raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
+        valid_params = [
+          :refresh,
+          :timeout,
+          :consistency,
+          :wait_for_completion,
+          :requests_per_second ]
+        method = 'POST'
+        path   = "_reindex"
+        params = Utils.__validate_and_extract_params arguments, valid_params
+        body   = arguments[:body]
+
+        perform_request(method, path, params, body).body
+      end
+    end
+  end
+end

elasticsearch-api/test/unit/reindex_test.rb

@@ -0,0 +1,26 @@
+require 'test_helper'
+
+module Elasticsearch
+  module Test
+    class ReindexTest < ::Test::Unit::TestCase
+
+      context "Reindex" do
+        subject { FakeClient.new }
+
+        should "perform correct request" do
+          subject.expects(:perform_request).with do |method, url, params, body|
+            assert_equal 'POST', method
+            assert_equal '_reindex', url
+            assert_equal Hash.new, params
+            assert_equal Hash.new, body
+            true
+          end.returns(FakeResponse.new)
+
+          subject.reindex :body => {}
+        end
+
+      end
+
+    end
+  end
+end