[API] Adds timeout and master_timeout parameters to indices endpoints

Author: picandocodigo

elasticsearch-api/lib/elasticsearch/api/actions/indices/create_data_stream.rb

@@ -25,6 +25,8 @@ module Actions
         # Creates a data stream
         #
         # @option arguments [String] :name The name of the data stream
+        # @option arguments [Time] :timeout Specify timeout for acknowledging the cluster state update
+        # @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/current/data-streams.html
@@ -48,7 +50,7 @@ def create_data_stream(arguments = {})
 
           method = Elasticsearch::API::HTTP_PUT
           path   = "_data_stream/#{Utils.__listify(_name)}"
-          params = {}
+          params = Utils.process_params(arguments)
 
           Elasticsearch::API::Response.new(
             perform_request(method, path, params, body, headers, request_opts)

elasticsearch-api/lib/elasticsearch/api/actions/indices/delete_data_stream.rb

@@ -26,6 +26,7 @@ module Actions
         #
         # @option arguments [List] :name A comma-separated list of data streams to delete; use `*` to delete 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] :master_timeout Specify timeout for connection to master
         # @option arguments [Hash] :headers Custom HTTP headers
         #
         # @see https://www.elastic.co/guide/en/elasticsearch/reference/current/data-streams.html

elasticsearch-api/lib/elasticsearch/api/actions/indices/get_data_lifecycle.rb

@@ -31,6 +31,7 @@ module Actions
         # @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/current/data-streams-get-lifecycle.html

elasticsearch-api/lib/elasticsearch/api/actions/indices/get_data_stream.rb

@@ -27,6 +27,7 @@ module Actions
         # @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/current/data-streams.html

elasticsearch-api/lib/elasticsearch/api/actions/indices/migrate_to_data_stream.rb

@@ -25,6 +25,8 @@ module Actions
         # Migrates an alias to a data stream
         #
         # @option arguments [String] :name The name of the alias to migrate
+        # @option arguments [Time] :timeout Specify timeout for acknowledging the cluster state update
+        # @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/current/data-streams.html
@@ -48,7 +50,7 @@ def migrate_to_data_stream(arguments = {})
 
           method = Elasticsearch::API::HTTP_POST
           path   = "_data_stream/_migrate/#{Utils.__listify(_name)}"
-          params = {}
+          params = Utils.process_params(arguments)
 
           Elasticsearch::API::Response.new(
             perform_request(method, path, params, body, headers, request_opts)

elasticsearch-api/lib/elasticsearch/api/actions/indices/promote_data_stream.rb

@@ -25,6 +25,7 @@ module Actions
         # Promotes a data stream from a replicated data stream managed by CCR to a regular data stream
         #
         # @option arguments [String] :name The name of the data stream
+        # @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/current/data-streams.html
@@ -48,7 +49,7 @@ def promote_data_stream(arguments = {})
 
           method = Elasticsearch::API::HTTP_POST
           path   = "_data_stream/_promote/#{Utils.__listify(_name)}"
-          params = {}
+          params = Utils.process_params(arguments)
 
           Elasticsearch::API::Response.new(
             perform_request(method, path, params, body, headers, request_opts)