diff --git a/elasticsearch-api/lib/elasticsearch/api/actions/esql/async_query.rb b/elasticsearch-api/lib/elasticsearch/api/actions/esql/async_query.rb index 51e6f17abc..41fe2ea7bb 100644 --- a/elasticsearch-api/lib/elasticsearch/api/actions/esql/async_query.rb +++ b/elasticsearch-api/lib/elasticsearch/api/actions/esql/async_query.rb @@ -19,38 +19,48 @@ # @see https://github.com/elastic/elasticsearch/tree/main/rest-api-spec # module Elasticsearch - module API - module Esql - module Actions - # Executes an ESQL request asynchronously - # - # @option arguments [String] :format a short version of the Accept header, e.g. json, yaml - # @option arguments [String] :delimiter The character to use between values within a CSV row. Only valid for the csv format. - # @option arguments [Boolean] :drop_null_columns Should entirely null columns be removed from the results? Their name and type will be returning in a new `all_columns` section. - # @option arguments [Hash] :headers Custom HTTP headers - # @option arguments [Hash] :body Use the `query` element to start a query. Use `columnar` to format the answer. (*Required*) - # - # @see https://www.elastic.co/guide/en/elasticsearch/reference/8.18/esql-async-query-api.html - # - def async_query(arguments = {}) - request_opts = { endpoint: arguments[:endpoint] || 'esql.async_query' } - - raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] - - arguments = arguments.clone - headers = arguments.delete(:headers) || {} - - body = arguments.delete(:body) - - method = Elasticsearch::API::HTTP_POST - path = '_query/async' - params = Utils.process_params(arguments) - - Elasticsearch::API::Response.new( - perform_request(method, path, params, body, headers, request_opts) - ) - end - end +module API + module Esql +module Actions + + # Executes an ESQL request asynchronously +# + # @option arguments [String] :format a short version of the Accept header, e.g. json, yaml + # @option arguments [String] :delimiter The character to use between values within a CSV row. Only valid for the csv format. + # @option arguments [Boolean] :drop_null_columns Should entirely null columns be removed from the results? Their name and type will be returning in a new `all_columns` section. + # @option arguments [Boolean] :allow_partial_results If `true`, partial results will be returned if there are shard failures, but +the query can continue to execute on other clusters and shards. +If `false`, the entire query will fail if there are +any failures. +# @option arguments [Hash] :headers Custom HTTP headers + # @option arguments [Hash] :body Use the `query` element to start a query. Use `columnar` to format the answer. (*Required*) +# +# @see https://www.elastic.co/guide/en/elasticsearch/reference/8.18/esql-async-query-api.html +# +def async_query(arguments = {}) + request_opts = { endpoint: arguments[:endpoint] || "esql.async_query" } + + + raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] + arguments = arguments.clone + headers = arguments.delete(:headers) || {} + + body = arguments.delete(:body) + + + +method = Elasticsearch::API::HTTP_POST +path = "_query/async" + params = Utils.process_params(arguments) + + + Elasticsearch::API::Response.new( + perform_request(method, path, params, body, headers, request_opts) + ) +end + + end + end end end diff --git a/elasticsearch-api/lib/elasticsearch/api/actions/esql/query.rb b/elasticsearch-api/lib/elasticsearch/api/actions/esql/query.rb index dd91bdb3ed..0d7c4b3dfa 100644 --- a/elasticsearch-api/lib/elasticsearch/api/actions/esql/query.rb +++ b/elasticsearch-api/lib/elasticsearch/api/actions/esql/query.rb @@ -19,38 +19,48 @@ # @see https://github.com/elastic/elasticsearch/tree/main/rest-api-spec # module Elasticsearch - module API - module Esql - module Actions - # Executes an ESQL request - # - # @option arguments [String] :format a short version of the Accept header, e.g. json, yaml - # @option arguments [String] :delimiter The character to use between values within a CSV row. Only valid for the csv format. - # @option arguments [Boolean] :drop_null_columns Should entirely null columns be removed from the results? Their name and type will be returning in a new `all_columns` section. - # @option arguments [Hash] :headers Custom HTTP headers - # @option arguments [Hash] :body Use the `query` element to start a query. Use `columnar` to format the answer. (*Required*) - # - # @see https://www.elastic.co/guide/en/elasticsearch/reference/8.18/esql-query-api.html - # - def query(arguments = {}) - request_opts = { endpoint: arguments[:endpoint] || 'esql.query' } - - raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] - - arguments = arguments.clone - headers = arguments.delete(:headers) || {} - - body = arguments.delete(:body) - - method = Elasticsearch::API::HTTP_POST - path = '_query' - params = Utils.process_params(arguments) - - Elasticsearch::API::Response.new( - perform_request(method, path, params, body, headers, request_opts) - ) - end - end +module API + module Esql +module Actions + + # Executes an ESQL request +# + # @option arguments [String] :format a short version of the Accept header, e.g. json, yaml + # @option arguments [String] :delimiter The character to use between values within a CSV row. Only valid for the csv format. + # @option arguments [Boolean] :drop_null_columns Should entirely null columns be removed from the results? Their name and type will be returning in a new `all_columns` section. + # @option arguments [Boolean] :allow_partial_results If `true`, partial results will be returned if there are shard failures, but +the query can continue to execute on other clusters and shards. +If `false`, the entire query will fail if there are +any failures. +# @option arguments [Hash] :headers Custom HTTP headers + # @option arguments [Hash] :body Use the `query` element to start a query. Use `columnar` to format the answer. (*Required*) +# +# @see https://www.elastic.co/guide/en/elasticsearch/reference/8.18/esql-query-api.html +# +def query(arguments = {}) + request_opts = { endpoint: arguments[:endpoint] || "esql.query" } + + + raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] + arguments = arguments.clone + headers = arguments.delete(:headers) || {} + + body = arguments.delete(:body) + + + +method = Elasticsearch::API::HTTP_POST +path = "_query" + params = Utils.process_params(arguments) + + + Elasticsearch::API::Response.new( + perform_request(method, path, params, body, headers, request_opts) + ) +end + + end + end end end diff --git a/elasticsearch-api/lib/elasticsearch/api/actions/indices/delete_data_stream_options.rb b/elasticsearch-api/lib/elasticsearch/api/actions/indices/delete_data_stream_options.rb new file mode 100644 index 0000000000..12c9532fc8 --- /dev/null +++ b/elasticsearch-api/lib/elasticsearch/api/actions/indices/delete_data_stream_options.rb @@ -0,0 +1,63 @@ +# Licensed to Elasticsearch B.V. under one or more contributor +# license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright +# ownership. Elasticsearch B.V. licenses this file to you under +# the Apache License, Version 2.0 (the "License"); you may +# not use this file except in compliance with the License. +# You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, +# software distributed under the License is distributed on an +# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +# KIND, either express or implied. See the License for the +# specific language governing permissions and limitations +# under the License. +# +# Auto generated from build hash f284cc16f4d4b4289bc679aa1529bb504190fe80 +# @see https://github.com/elastic/elasticsearch/tree/main/rest-api-spec +# +module Elasticsearch + module API + module Indices + module Actions + # Deletes the data stream options of the selected data streams. + # + # @option arguments [List] :name A comma-separated list of data streams of which the data stream options will be deleted; use `*` to get all data streams + # @option arguments [String] :expand_wildcards Whether wildcard expressions should get expanded to open or closed indices (default: open) (options: open, closed, hidden, none, all) + # @option arguments [Time] :timeout Explicit timestamp for the document + # @option arguments [Time] :master_timeout Specify timeout for connection to master + # @option arguments [Hash] :headers Custom HTTP headers + # + # @see https://www.elastic.co/guide/en/elasticsearch/reference/8.18/index.html + # + def delete_data_stream_options(arguments = {}) + request_opts = { endpoint: arguments[:endpoint] || 'indices.delete_data_stream_options' } + + defined_params = [:name].each_with_object({}) do |variable, set_variables| + set_variables[variable] = arguments[variable] if arguments.key?(variable) + end + request_opts[:defined_params] = defined_params unless defined_params.empty? + + raise ArgumentError, "Required argument 'name' missing" unless arguments[:name] + + arguments = arguments.clone + headers = arguments.delete(:headers) || {} + + body = nil + + _name = arguments.delete(:name) + + method = Elasticsearch::API::HTTP_DELETE + path = "_data_stream/#{Utils.__listify(_name)}/_options" + params = Utils.process_params(arguments) + + Elasticsearch::API::Response.new( + perform_request(method, path, params, body, headers, request_opts) + ) + end + end + end + end +end diff --git a/elasticsearch-api/lib/elasticsearch/api/actions/indices/get_data_stream_options.rb b/elasticsearch-api/lib/elasticsearch/api/actions/indices/get_data_stream_options.rb new file mode 100644 index 0000000000..20cd3b94a7 --- /dev/null +++ b/elasticsearch-api/lib/elasticsearch/api/actions/indices/get_data_stream_options.rb @@ -0,0 +1,63 @@ +# Licensed to Elasticsearch B.V. under one or more contributor +# license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright +# ownership. Elasticsearch B.V. licenses this file to you under +# the Apache License, Version 2.0 (the "License"); you may +# not use this file except in compliance with the License. +# You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, +# software distributed under the License is distributed on an +# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +# KIND, either express or implied. See the License for the +# specific language governing permissions and limitations +# under the License. +# +# Auto generated from build hash f284cc16f4d4b4289bc679aa1529bb504190fe80 +# @see https://github.com/elastic/elasticsearch/tree/main/rest-api-spec +# +module Elasticsearch + module API + module Indices + module Actions + # Returns the data stream options of the selected data streams. + # + # @option arguments [List] :name A comma-separated list of data streams to get; use `*` to get all data streams + # @option arguments [String] :expand_wildcards Whether wildcard expressions should get expanded to open or closed indices (default: open) (options: open, closed, hidden, none, all) + # @option arguments [Boolean] :include_defaults Return all relevant default configurations for the data stream (default: false) + # @option arguments [Time] :master_timeout Specify timeout for connection to master + # @option arguments [Hash] :headers Custom HTTP headers + # + # @see https://www.elastic.co/guide/en/elasticsearch/reference/8.18/index.html + # + def get_data_stream_options(arguments = {}) + request_opts = { endpoint: arguments[:endpoint] || 'indices.get_data_stream_options' } + + defined_params = [:name].each_with_object({}) do |variable, set_variables| + set_variables[variable] = arguments[variable] if arguments.key?(variable) + end + request_opts[:defined_params] = defined_params unless defined_params.empty? + + raise ArgumentError, "Required argument 'name' missing" unless arguments[:name] + + arguments = arguments.clone + headers = arguments.delete(:headers) || {} + + body = nil + + _name = arguments.delete(:name) + + method = Elasticsearch::API::HTTP_GET + path = "_data_stream/#{Utils.__listify(_name)}/_options" + params = Utils.process_params(arguments) + + Elasticsearch::API::Response.new( + perform_request(method, path, params, body, headers, request_opts) + ) + end + end + end + end +end diff --git a/elasticsearch-api/lib/elasticsearch/api/actions/indices/put_data_stream_options.rb b/elasticsearch-api/lib/elasticsearch/api/actions/indices/put_data_stream_options.rb new file mode 100644 index 0000000000..608afd1f05 --- /dev/null +++ b/elasticsearch-api/lib/elasticsearch/api/actions/indices/put_data_stream_options.rb @@ -0,0 +1,64 @@ +# Licensed to Elasticsearch B.V. under one or more contributor +# license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright +# ownership. Elasticsearch B.V. licenses this file to you under +# the Apache License, Version 2.0 (the "License"); you may +# not use this file except in compliance with the License. +# You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, +# software distributed under the License is distributed on an +# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +# KIND, either express or implied. See the License for the +# specific language governing permissions and limitations +# under the License. +# +# Auto generated from build hash f284cc16f4d4b4289bc679aa1529bb504190fe80 +# @see https://github.com/elastic/elasticsearch/tree/main/rest-api-spec +# +module Elasticsearch + module API + module Indices + module Actions + # Updates the data stream options of the selected data streams. + # + # @option arguments [List] :name A comma-separated list of data streams whose options will be updated; use `*` to set the options to all data streams + # @option arguments [String] :expand_wildcards Whether wildcard expressions should get expanded to open or closed indices (default: open) (options: open, closed, hidden, none, all) + # @option arguments [Time] :timeout Explicit timestamp for the document + # @option arguments [Time] :master_timeout Specify timeout for connection to master + # @option arguments [Hash] :headers Custom HTTP headers + # @option arguments [Hash] :body The data stream options configuration that consist of the failure store configuration + # + # @see https://www.elastic.co/guide/en/elasticsearch/reference/8.18/index.html + # + def put_data_stream_options(arguments = {}) + request_opts = { endpoint: arguments[:endpoint] || 'indices.put_data_stream_options' } + + defined_params = [:name].each_with_object({}) do |variable, set_variables| + set_variables[variable] = arguments[variable] if arguments.key?(variable) + end + request_opts[:defined_params] = defined_params unless defined_params.empty? + + raise ArgumentError, "Required argument 'name' missing" unless arguments[:name] + + arguments = arguments.clone + headers = arguments.delete(:headers) || {} + + body = arguments.delete(:body) + + _name = arguments.delete(:name) + + method = Elasticsearch::API::HTTP_PUT + path = "_data_stream/#{Utils.__listify(_name)}/_options" + params = Utils.process_params(arguments) + + Elasticsearch::API::Response.new( + perform_request(method, path, params, body, headers, request_opts) + ) + end + end + end + end +end