lib/elasticsearch/api/actions/indices/rollover.rb in elasticsearch-api-7.17.11 vs lib/elasticsearch/api/actions/indices/rollover.rb in elasticsearch-api-8.0.0.pre1
- old
+ new
@@ -22,25 +22,26 @@
# Updates an alias to point to a new index when the existing index
# is considered to be too large or too old.
#
# @option arguments [String] :alias The name of the alias to rollover
# @option arguments [String] :new_index The name of the rollover index
- # @option arguments [Boolean] :include_type_name Whether a type should be included in the body of the mappings.
# @option arguments [Time] :timeout Explicit operation timeout
# @option arguments [Boolean] :dry_run If set to true the rollover action will only be validated but not actually performed even if a condition matches. The default is false
# @option arguments [Time] :master_timeout Specify timeout for connection to master
# @option arguments [String] :wait_for_active_shards Set the number of active shards to wait for on the newly created rollover index before the operation returns.
# @option arguments [Hash] :headers Custom HTTP headers
# @option arguments [Hash] :body The conditions that needs to be met for executing rollover
#
- # @see https://www.elastic.co/guide/en/elasticsearch/reference/7.17/indices-rollover-index.html
+ # @see https://www.elastic.co/guide/en/elasticsearch/reference/master/indices-rollover-index.html
#
def rollover(arguments = {})
raise ArgumentError, "Required argument 'alias' missing" unless arguments[:alias]
headers = arguments.delete(:headers) || {}
+ body = arguments.delete(:body)
+
arguments = arguments.clone
_alias = arguments.delete(:alias)
_new_index = arguments.delete(:new_index)
@@ -49,25 +50,15 @@
path = if _alias && _new_index
"#{Utils.__listify(_alias)}/_rollover/#{Utils.__listify(_new_index)}"
else
"#{Utils.__listify(_alias)}/_rollover"
end
- params = Utils.__validate_and_extract_params arguments, ParamsRegistry.get(__method__)
+ params = Utils.process_params(arguments)
- body = arguments[:body]
- perform_request(method, path, params, body, headers).body
+ Elasticsearch::API::Response.new(
+ perform_request(method, path, params, body, headers)
+ )
end
-
- # Register this action with its valid params when the module is loaded.
- #
- # @since 6.2.0
- ParamsRegistry.register(:rollover, [
- :include_type_name,
- :timeout,
- :dry_run,
- :master_timeout,
- :wait_for_active_shards
- ].freeze)
end
end
end
end