lib/elasticsearch/api/actions/transform/reset_transform.rb in elasticsearch-api-8.10.0 vs lib/elasticsearch/api/actions/transform/reset_transform.rb in elasticsearch-api-8.11.0

- old
+ new

@@ -27,13 +27,21 @@ # @option arguments [String] :transform_id The id of the transform to reset # @option arguments [Boolean] :force When `true`, the transform is reset regardless of its current state. The default value is `false`, meaning that the transform must be `stopped` before it can be reset. # @option arguments [Time] :timeout Controls the time to wait for the transform to reset # @option arguments [Hash] :headers Custom HTTP headers # - # @see https://www.elastic.co/guide/en/elasticsearch/reference/8.10/reset-transform.html + # @see https://www.elastic.co/guide/en/elasticsearch/reference/8.11/reset-transform.html # def reset_transform(arguments = {}) + request_opts = { endpoint: arguments[:endpoint] || "transform.reset_transform" } + + defined_params = [:transform_id].inject({}) do |set_variables, variable| + set_variables[variable] = arguments[variable] if arguments.key?(variable) + set_variables + end + request_opts[:defined_params] = defined_params unless defined_params.empty? + raise ArgumentError, "Required argument 'transform_id' missing" unless arguments[:transform_id] arguments = arguments.clone headers = arguments.delete(:headers) || {} @@ -44,10 +52,10 @@ method = Elasticsearch::API::HTTP_POST path = "_transform/#{Utils.__listify(_transform_id)}/_reset" params = Utils.process_params(arguments) Elasticsearch::API::Response.new( - perform_request(method, path, params, body, headers) + perform_request(method, path, params, body, headers, request_opts) ) end end end end