Module: ElasticsearchServerless::API::Indices::Actions
- Defined in:
- lib/elasticsearch-serverless/api/indices/get.rb,
lib/elasticsearch-serverless/api/indices/create.rb,
lib/elasticsearch-serverless/api/indices/delete.rb,
lib/elasticsearch-serverless/api/indices/exists.rb,
lib/elasticsearch-serverless/api/indices/analyze.rb,
lib/elasticsearch-serverless/api/indices/refresh.rb,
lib/elasticsearch-serverless/api/indices/rollover.rb,
lib/elasticsearch-serverless/api/indices/add_block.rb,
lib/elasticsearch-serverless/api/indices/get_alias.rb,
lib/elasticsearch-serverless/api/indices/put_alias.rb,
lib/elasticsearch-serverless/api/indices/get_mapping.rb,
lib/elasticsearch-serverless/api/indices/put_mapping.rb,
lib/elasticsearch-serverless/api/indices/delete_alias.rb,
lib/elasticsearch-serverless/api/indices/exists_alias.rb,
lib/elasticsearch-serverless/api/indices/get_settings.rb,
lib/elasticsearch-serverless/api/indices/put_settings.rb,
lib/elasticsearch-serverless/api/indices/resolve_index.rb,
lib/elasticsearch-serverless/api/indices/update_aliases.rb,
lib/elasticsearch-serverless/api/indices/validate_query.rb,
lib/elasticsearch-serverless/api/indices/get_data_stream.rb,
lib/elasticsearch-serverless/api/indices/simulate_template.rb,
lib/elasticsearch-serverless/api/indices/create_data_stream.rb,
lib/elasticsearch-serverless/api/indices/data_streams_stats.rb,
lib/elasticsearch-serverless/api/indices/delete_data_stream.rb,
lib/elasticsearch-serverless/api/indices/get_data_lifecycle.rb,
lib/elasticsearch-serverless/api/indices/get_index_template.rb,
lib/elasticsearch-serverless/api/indices/modify_data_stream.rb,
lib/elasticsearch-serverless/api/indices/put_data_lifecycle.rb,
lib/elasticsearch-serverless/api/indices/put_index_template.rb,
lib/elasticsearch-serverless/api/indices/delete_data_lifecycle.rb,
lib/elasticsearch-serverless/api/indices/delete_index_template.rb,
lib/elasticsearch-serverless/api/indices/exists_index_template.rb,
lib/elasticsearch-serverless/api/indices/explain_data_lifecycle.rb,
lib/elasticsearch-serverless/api/indices/migrate_to_data_stream.rb,
lib/elasticsearch-serverless/api/indices/simulate_index_template.rb
Instance Method Summary collapse
-
#add_block(arguments = {}) ⇒ Object
Adds a block to an index.
-
#analyze(arguments = {}) ⇒ Object
Performs the analysis process on a text and return the tokens breakdown of the text.
-
#create(arguments = {}) ⇒ Object
Creates an index with optional settings and mappings.
-
#create_data_stream(arguments = {}) ⇒ Object
Creates a data stream.
-
#data_streams_stats(arguments = {}) ⇒ Object
Provides statistics on operations happening in a data stream.
-
#delete(arguments = {}) ⇒ Object
Deletes an index.
-
#delete_alias(arguments = {}) ⇒ Object
Deletes an alias.
-
#delete_data_lifecycle(arguments = {}) ⇒ Object
Deletes the data stream lifecycle of the selected data streams.
-
#delete_data_stream(arguments = {}) ⇒ Object
Deletes a data stream.
-
#delete_index_template(arguments = {}) ⇒ Object
Deletes an index template.
-
#exists(arguments = {}) ⇒ Object
(also: #exists?)
Returns information about whether a particular index exists.
-
#exists_alias(arguments = {}) ⇒ Object
(also: #exists_alias?)
Returns information about whether a particular alias exists.
-
#exists_index_template(arguments = {}) ⇒ Object
(also: #exists_index_template?)
Returns information about whether a particular index template exists.
-
#explain_data_lifecycle(arguments = {}) ⇒ Object
Retrieves information about the index’s current data stream lifecycle, such as any potential encountered error, time since creation etc.
-
#get(arguments = {}) ⇒ Object
Returns information about one or more indices.
-
#get_alias(arguments = {}) ⇒ Object
Returns an alias.
-
#get_data_lifecycle(arguments = {}) ⇒ Object
Returns the data stream lifecycle of the selected data streams.
-
#get_data_stream(arguments = {}) ⇒ Object
Returns data streams.
-
#get_index_template(arguments = {}) ⇒ Object
Returns an index template.
-
#get_mapping(arguments = {}) ⇒ Object
Returns mappings for one or more indices.
-
#get_settings(arguments = {}) ⇒ Object
Returns settings for one or more indices.
-
#migrate_to_data_stream(arguments = {}) ⇒ Object
Migrates an alias to a data stream.
-
#modify_data_stream(arguments = {}) ⇒ Object
Modifies a data stream.
-
#put_alias(arguments = {}) ⇒ Object
Creates or updates an alias.
-
#put_data_lifecycle(arguments = {}) ⇒ Object
Updates the data stream lifecycle of the selected data streams.
-
#put_index_template(arguments = {}) ⇒ Object
Creates or updates an index template.
-
#put_mapping(arguments = {}) ⇒ Object
Updates the index mappings.
-
#put_settings(arguments = {}) ⇒ Object
Updates the index settings.
-
#refresh(arguments = {}) ⇒ Object
Performs the refresh operation in one or more indices.
-
#resolve_index(arguments = {}) ⇒ Object
Returns information about any matching indices, aliases, and data streams.
-
#rollover(arguments = {}) ⇒ Object
Updates an alias to point to a new index when the existing index is considered to be too large or too old.
-
#simulate_index_template(arguments = {}) ⇒ Object
Simulate matching the given index name against the index templates in the system.
-
#simulate_template(arguments = {}) ⇒ Object
Simulate resolving the given template name or body.
-
#update_aliases(arguments = {}) ⇒ Object
Updates index aliases.
-
#validate_query(arguments = {}) ⇒ Object
Allows a user to validate a potentially expensive query without executing it.
Instance Method Details
#add_block(arguments = {}) ⇒ Object
Adds a block to an index.
38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 |
# File 'lib/elasticsearch-serverless/api/indices/add_block.rb', line 38 def add_block(arguments = {}) raise ArgumentError, "Required argument 'index' missing" unless arguments[:index] raise ArgumentError, "Required argument 'block' missing" unless arguments[:block] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _index = arguments.delete(:index) _block = arguments.delete(:block) method = ElasticsearchServerless::API::HTTP_PUT path = "#{Utils.listify(_index)}/_block/#{Utils.listify(_block)}" params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#analyze(arguments = {}) ⇒ Object
Performs the analysis process on a text and return the tokens breakdown of the text.
33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 |
# File 'lib/elasticsearch-serverless/api/indices/analyze.rb', line 33 def analyze(arguments = {}) arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _index = arguments.delete(:index) method = if body ElasticsearchServerless::API::HTTP_POST else ElasticsearchServerless::API::HTTP_GET end path = if _index "#{Utils.listify(_index)}/_analyze" else "_analyze" end params = {} ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#create(arguments = {}) ⇒ Object
Creates an index with optional settings and mappings.
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 |
# File 'lib/elasticsearch-serverless/api/indices/create.rb', line 36 def create(arguments = {}) raise ArgumentError, "Required argument 'index' missing" unless arguments[:index] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _index = arguments.delete(:index) method = ElasticsearchServerless::API::HTTP_PUT path = "#{Utils.listify(_index)}" params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#create_data_stream(arguments = {}) ⇒ Object
Creates a data stream
32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 |
# File 'lib/elasticsearch-serverless/api/indices/create_data_stream.rb', line 32 def create_data_stream(arguments = {}) raise ArgumentError, "Required argument 'name' missing" unless arguments[:name] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _name = arguments.delete(:name) method = ElasticsearchServerless::API::HTTP_PUT path = "_data_stream/#{Utils.listify(_name)}" params = {} ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#data_streams_stats(arguments = {}) ⇒ Object
Provides statistics on operations happening in a data stream.
33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 |
# File 'lib/elasticsearch-serverless/api/indices/data_streams_stats.rb', line 33 def data_streams_stats(arguments = {}) arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _name = arguments.delete(:name) method = ElasticsearchServerless::API::HTTP_GET path = if _name "_data_stream/#{Utils.listify(_name)}/_stats" else "_data_stream/_stats" end params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#delete(arguments = {}) ⇒ Object
Deletes an index.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 |
# File 'lib/elasticsearch-serverless/api/indices/delete.rb', line 37 def delete(arguments = {}) raise ArgumentError, "Required argument 'index' missing" unless arguments[:index] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _index = arguments.delete(:index) method = ElasticsearchServerless::API::HTTP_DELETE path = "#{Utils.listify(_index)}" params = Utils.process_params(arguments) if Array(arguments[:ignore]).include?(404) Utils.rescue_from_not_found { ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) } else ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end end |
#delete_alias(arguments = {}) ⇒ Object
Deletes an alias.
35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 |
# File 'lib/elasticsearch-serverless/api/indices/delete_alias.rb', line 35 def delete_alias(arguments = {}) raise ArgumentError, "Required argument 'index' missing" unless arguments[:index] raise ArgumentError, "Required argument 'name' missing" unless arguments[:name] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _index = arguments.delete(:index) _name = arguments.delete(:name) method = ElasticsearchServerless::API::HTTP_DELETE path = if _index && _name "#{Utils.listify(_index)}/_aliases/#{Utils.listify(_name)}" end params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#delete_data_lifecycle(arguments = {}) ⇒ Object
Deletes the data stream lifecycle of the selected data streams.
35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 |
# File 'lib/elasticsearch-serverless/api/indices/delete_data_lifecycle.rb', line 35 def delete_data_lifecycle(arguments = {}) raise ArgumentError, "Required argument 'name' missing" unless arguments[:name] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _name = arguments.delete(:name) method = ElasticsearchServerless::API::HTTP_DELETE path = "_data_stream/#{Utils.listify(_name)}/_lifecycle" params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#delete_data_stream(arguments = {}) ⇒ Object
Deletes a data stream.
33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 |
# File 'lib/elasticsearch-serverless/api/indices/delete_data_stream.rb', line 33 def delete_data_stream(arguments = {}) raise ArgumentError, "Required argument 'name' missing" unless arguments[:name] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _name = arguments.delete(:name) method = ElasticsearchServerless::API::HTTP_DELETE path = "_data_stream/#{Utils.listify(_name)}" params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#delete_index_template(arguments = {}) ⇒ Object
Deletes an index template.
34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 |
# File 'lib/elasticsearch-serverless/api/indices/delete_index_template.rb', line 34 def delete_index_template(arguments = {}) raise ArgumentError, "Required argument 'name' missing" unless arguments[:name] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _name = arguments.delete(:name) method = ElasticsearchServerless::API::HTTP_DELETE path = "_index_template/#{Utils.listify(_name)}" params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#exists(arguments = {}) ⇒ Object Also known as: exists?
Returns information about whether a particular index exists.
38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 |
# File 'lib/elasticsearch-serverless/api/indices/exists.rb', line 38 def exists(arguments = {}) raise ArgumentError, "Required argument 'index' missing" unless arguments[:index] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _index = arguments.delete(:index) method = ElasticsearchServerless::API::HTTP_HEAD path = "#{Utils.listify(_index)}" params = Utils.process_params(arguments) Utils.rescue_from_not_found do perform_request(method, path, params, body, headers).status == 200 ? true : false end end |
#exists_alias(arguments = {}) ⇒ Object Also known as: exists_alias?
Returns information about whether a particular alias exists.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 |
# File 'lib/elasticsearch-serverless/api/indices/exists_alias.rb', line 37 def exists_alias(arguments = {}) raise ArgumentError, "Required argument 'name' missing" unless arguments[:name] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _name = arguments.delete(:name) _index = arguments.delete(:index) method = ElasticsearchServerless::API::HTTP_HEAD path = if _index && _name "#{Utils.listify(_index)}/_alias/#{Utils.listify(_name)}" else "_alias/#{Utils.listify(_name)}" end params = Utils.process_params(arguments) Utils.rescue_from_not_found do perform_request(method, path, params, body, headers).status == 200 ? true : false end end |
#exists_index_template(arguments = {}) ⇒ Object Also known as: exists_index_template?
Returns information about whether a particular index template exists.
33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 |
# File 'lib/elasticsearch-serverless/api/indices/exists_index_template.rb', line 33 def exists_index_template(arguments = {}) raise ArgumentError, "Required argument 'name' missing" unless arguments[:name] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _name = arguments.delete(:name) method = ElasticsearchServerless::API::HTTP_HEAD path = "_index_template/#{Utils.listify(_name)}" params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#explain_data_lifecycle(arguments = {}) ⇒ Object
Retrieves information about the index’s current data stream lifecycle, such as any potential encountered error, time since creation etc.
34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 |
# File 'lib/elasticsearch-serverless/api/indices/explain_data_lifecycle.rb', line 34 def explain_data_lifecycle(arguments = {}) raise ArgumentError, "Required argument 'index' missing" unless arguments[:index] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _index = arguments.delete(:index) method = ElasticsearchServerless::API::HTTP_GET path = "#{Utils.listify(_index)}/_lifecycle/explain" params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#get(arguments = {}) ⇒ Object
Returns information about one or more indices.
40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 |
# File 'lib/elasticsearch-serverless/api/indices/get.rb', line 40 def get(arguments = {}) raise ArgumentError, "Required argument 'index' missing" unless arguments[:index] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _index = arguments.delete(:index) method = ElasticsearchServerless::API::HTTP_GET path = "#{Utils.listify(_index)}" params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#get_alias(arguments = {}) ⇒ Object
Returns an alias.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 |
# File 'lib/elasticsearch-serverless/api/indices/get_alias.rb', line 37 def get_alias(arguments = {}) arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _name = arguments.delete(:name) _index = arguments.delete(:index) method = ElasticsearchServerless::API::HTTP_GET path = if _index && _name "#{Utils.listify(_index)}/_alias/#{Utils.listify(_name)}" elsif _index "#{Utils.listify(_index)}/_alias" elsif _name "_alias/#{Utils.listify(_name)}" else "_alias" end params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#get_data_lifecycle(arguments = {}) ⇒ Object
Returns the data stream lifecycle of the selected data streams.
34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 |
# File 'lib/elasticsearch-serverless/api/indices/get_data_lifecycle.rb', line 34 def get_data_lifecycle(arguments = {}) raise ArgumentError, "Required argument 'name' missing" unless arguments[:name] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _name = arguments.delete(:name) method = ElasticsearchServerless::API::HTTP_GET path = "_data_stream/#{Utils.listify(_name)}/_lifecycle" params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#get_data_stream(arguments = {}) ⇒ Object
Returns data streams.
34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 |
# File 'lib/elasticsearch-serverless/api/indices/get_data_stream.rb', line 34 def get_data_stream(arguments = {}) arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _name = arguments.delete(:name) method = ElasticsearchServerless::API::HTTP_GET path = if _name "_data_stream/#{Utils.listify(_name)}" else "_data_stream" end params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#get_index_template(arguments = {}) ⇒ Object
Returns an index template.
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 |
# File 'lib/elasticsearch-serverless/api/indices/get_index_template.rb', line 36 def get_index_template(arguments = {}) arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _name = arguments.delete(:name) method = ElasticsearchServerless::API::HTTP_GET path = if _name "_index_template/#{Utils.listify(_name)}" else "_index_template" end params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#get_mapping(arguments = {}) ⇒ Object
Returns mappings for one or more indices.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 |
# File 'lib/elasticsearch-serverless/api/indices/get_mapping.rb', line 37 def get_mapping(arguments = {}) arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _index = arguments.delete(:index) method = ElasticsearchServerless::API::HTTP_GET path = if _index "#{Utils.listify(_index)}/_mapping" else "_mapping" end params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#get_settings(arguments = {}) ⇒ Object
Returns settings for one or more indices.
40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 |
# File 'lib/elasticsearch-serverless/api/indices/get_settings.rb', line 40 def get_settings(arguments = {}) arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _index = arguments.delete(:index) _name = arguments.delete(:name) method = ElasticsearchServerless::API::HTTP_GET path = if _index && _name "#{Utils.listify(_index)}/_settings/#{Utils.listify(_name)}" elsif _index "#{Utils.listify(_index)}/_settings" elsif _name "_settings/#{Utils.listify(_name)}" else "_settings" end params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#migrate_to_data_stream(arguments = {}) ⇒ Object
Migrates an alias to a data stream
32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 |
# File 'lib/elasticsearch-serverless/api/indices/migrate_to_data_stream.rb', line 32 def migrate_to_data_stream(arguments = {}) raise ArgumentError, "Required argument 'name' missing" unless arguments[:name] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _name = arguments.delete(:name) method = ElasticsearchServerless::API::HTTP_POST path = "_data_stream/_migrate/#{Utils.listify(_name)}" params = {} ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#modify_data_stream(arguments = {}) ⇒ Object
Modifies a data stream
32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 |
# File 'lib/elasticsearch-serverless/api/indices/modify_data_stream.rb', line 32 def modify_data_stream(arguments = {}) raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) method = ElasticsearchServerless::API::HTTP_POST path = "_data_stream/_modify" params = {} ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#put_alias(arguments = {}) ⇒ Object
Creates or updates an alias.
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 |
# File 'lib/elasticsearch-serverless/api/indices/put_alias.rb', line 36 def put_alias(arguments = {}) raise ArgumentError, "Required argument 'index' missing" unless arguments[:index] raise ArgumentError, "Required argument 'name' missing" unless arguments[:name] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _index = arguments.delete(:index) _name = arguments.delete(:name) method = ElasticsearchServerless::API::HTTP_PUT path = if _index && _name "#{Utils.listify(_index)}/_aliases/#{Utils.listify(_name)}" end params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#put_data_lifecycle(arguments = {}) ⇒ Object
Updates the data stream lifecycle of the selected data streams.
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 |
# File 'lib/elasticsearch-serverless/api/indices/put_data_lifecycle.rb', line 36 def put_data_lifecycle(arguments = {}) 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 = ElasticsearchServerless::API::HTTP_PUT path = "_data_stream/#{Utils.listify(_name)}/_lifecycle" params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#put_index_template(arguments = {}) ⇒ Object
Creates or updates an index template.
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 |
# File 'lib/elasticsearch-serverless/api/indices/put_index_template.rb', line 36 def put_index_template(arguments = {}) raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] 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 = ElasticsearchServerless::API::HTTP_PUT path = "_index_template/#{Utils.listify(_name)}" params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#put_mapping(arguments = {}) ⇒ Object
Updates the index mappings.
39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 |
# File 'lib/elasticsearch-serverless/api/indices/put_mapping.rb', line 39 def put_mapping(arguments = {}) raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] raise ArgumentError, "Required argument 'index' missing" unless arguments[:index] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _index = arguments.delete(:index) method = ElasticsearchServerless::API::HTTP_PUT path = "#{Utils.listify(_index)}/_mapping" params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#put_settings(arguments = {}) ⇒ Object
Updates the index settings.
40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 |
# File 'lib/elasticsearch-serverless/api/indices/put_settings.rb', line 40 def put_settings(arguments = {}) raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _index = arguments.delete(:index) method = ElasticsearchServerless::API::HTTP_PUT path = if _index "#{Utils.listify(_index)}/_settings" else "_settings" end params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#refresh(arguments = {}) ⇒ Object
Performs the refresh operation in one or more indices.
35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 |
# File 'lib/elasticsearch-serverless/api/indices/refresh.rb', line 35 def refresh(arguments = {}) arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _index = arguments.delete(:index) method = ElasticsearchServerless::API::HTTP_POST path = if _index "#{Utils.listify(_index)}/_refresh" else "_refresh" end params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#resolve_index(arguments = {}) ⇒ Object
Returns information about any matching indices, aliases, and data streams
33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 |
# File 'lib/elasticsearch-serverless/api/indices/resolve_index.rb', line 33 def resolve_index(arguments = {}) raise ArgumentError, "Required argument 'name' missing" unless arguments[:name] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _name = arguments.delete(:name) method = ElasticsearchServerless::API::HTTP_GET path = "_resolve/index/#{Utils.listify(_name)}" params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#rollover(arguments = {}) ⇒ Object
Updates an alias to point to a new index when the existing index is considered to be too large or too old.
39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 |
# File 'lib/elasticsearch-serverless/api/indices/rollover.rb', line 39 def rollover(arguments = {}) raise ArgumentError, "Required argument 'alias' missing" unless arguments[:alias] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _alias = arguments.delete(:alias) _new_index = arguments.delete(:new_index) method = ElasticsearchServerless::API::HTTP_POST path = if _alias && _new_index "#{Utils.listify(_alias)}/_rollover/#{Utils.listify(_new_index)}" else "#{Utils.listify(_alias)}/_rollover" end params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#simulate_index_template(arguments = {}) ⇒ Object
Simulate matching the given index name against the index templates in the system
34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 |
# File 'lib/elasticsearch-serverless/api/indices/simulate_index_template.rb', line 34 def simulate_index_template(arguments = {}) raise ArgumentError, "Required argument 'name' missing" unless arguments[:name] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _name = arguments.delete(:name) method = ElasticsearchServerless::API::HTTP_POST path = "_index_template/_simulate_index/#{Utils.listify(_name)}" params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#simulate_template(arguments = {}) ⇒ Object
Simulate resolving the given template name or body
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 |
# File 'lib/elasticsearch-serverless/api/indices/simulate_template.rb', line 36 def simulate_template(arguments = {}) arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _name = arguments.delete(:name) method = ElasticsearchServerless::API::HTTP_POST path = if _name "_index_template/_simulate/#{Utils.listify(_name)}" else "_index_template/_simulate" end params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#update_aliases(arguments = {}) ⇒ Object
Updates index aliases.
34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 |
# File 'lib/elasticsearch-serverless/api/indices/update_aliases.rb', line 34 def update_aliases(arguments = {}) raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) method = ElasticsearchServerless::API::HTTP_POST path = "_aliases" params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#validate_query(arguments = {}) ⇒ Object
Allows a user to validate a potentially expensive query without executing it.
45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 |
# File 'lib/elasticsearch-serverless/api/indices/validate_query.rb', line 45 def validate_query(arguments = {}) arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _index = arguments.delete(:index) method = if body ElasticsearchServerless::API::HTTP_POST else ElasticsearchServerless::API::HTTP_GET end path = if _index "#{Utils.listify(_index)}/_validate/query" else "_validate/query" end params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |