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/put_template.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 analysis on a text string and returns the resulting tokens.
-
#create(arguments = {}) ⇒ Object
Creates a new index.
-
#create_data_stream(arguments = {}) ⇒ Object
Creates a data stream.
-
#data_streams_stats(arguments = {}) ⇒ Object
Retrieves statistics for one or more data streams.
-
#delete(arguments = {}) ⇒ Object
Deletes one or more indices.
-
#delete_alias(arguments = {}) ⇒ Object
Removes a data stream or index from an alias.
-
#delete_data_lifecycle(arguments = {}) ⇒ Object
Removes the data lifecycle from a data stream rendering it not managed by the data stream lifecycle.
-
#delete_data_stream(arguments = {}) ⇒ Object
Deletes one or more data streams and their backing indices.
-
#delete_index_template(arguments = {}) ⇒ Object
Delete an index template.
-
#exists(arguments = {}) ⇒ Object
(also: #exists?)
Checks if a data stream, index, or alias exists.
-
#exists_alias(arguments = {}) ⇒ Object
(also: #exists_alias?)
Checks if an 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
Retrieves information for one or more aliases.
-
#get_data_lifecycle(arguments = {}) ⇒ Object
Retrieves the data stream lifecycle configuration of one or more data streams.
-
#get_data_stream(arguments = {}) ⇒ Object
Retrieves information about one or more data streams.
-
#get_index_template(arguments = {}) ⇒ Object
Get index templates.
-
#get_mapping(arguments = {}) ⇒ Object
Retrieves mapping definitions for one or more indices.
-
#get_settings(arguments = {}) ⇒ Object
Returns setting information for one or more indices.
-
#migrate_to_data_stream(arguments = {}) ⇒ Object
Converts an index alias to a data stream.
-
#modify_data_stream(arguments = {}) ⇒ Object
Performs one or more data stream modification actions in a single atomic operation.
-
#put_alias(arguments = {}) ⇒ Object
Adds a data stream or index to an alias.
-
#put_data_lifecycle(arguments = {}) ⇒ Object
Update the data lifecycle of the specified data streams.
-
#put_index_template(arguments = {}) ⇒ Object
Create or update an index template.
-
#put_mapping(arguments = {}) ⇒ Object
Adds new fields to an existing data stream or index.
-
#put_settings(arguments = {}) ⇒ Object
Changes a dynamic index setting in real time.
-
#put_template(arguments = {}) ⇒ Object
Create or update an index template.
-
#refresh(arguments = {}) ⇒ Object
A refresh makes recent operations performed on one or more indices available for search.
-
#resolve_index(arguments = {}) ⇒ Object
Resolves the specified name(s) and/or index patterns for indices, aliases, and data streams.
-
#rollover(arguments = {}) ⇒ Object
Creates a new index for a data stream or index alias.
-
#simulate_index_template(arguments = {}) ⇒ Object
Simulate an index.
-
#simulate_template(arguments = {}) ⇒ Object
Simulate an index template.
-
#update_aliases(arguments = {}) ⇒ Object
Adds a data stream or index to an alias.
-
#validate_query(arguments = {}) ⇒ Object
Validates 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 analysis on a text string and returns the resulting tokens.
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 a new index.
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. You must have a matching index template with data stream enabled.
33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 |
# File 'lib/elasticsearch-serverless/api/indices/create_data_stream.rb', line 33 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
Retrieves statistics for one or more data streams.
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 one or more indices.
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
Removes a data stream or index from 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
Removes the data lifecycle from a data stream rendering it not managed by the data stream lifecycle
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 one or more data streams and their backing indices.
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
Delete an index template. The provided <index-template> may contain multiple template names separated by a comma. If multiple template names are specified then there is no wildcard support and the provided names should match completely with existing templates.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 |
# File 'lib/elasticsearch-serverless/api/indices/delete_index_template.rb', line 37 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?
Checks if a data stream, index, or alias 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?
Checks if an 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. For data streams, the API returns information about the stream’s backing indices.
41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 |
# File 'lib/elasticsearch-serverless/api/indices/get.rb', line 41 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
Retrieves information for one or more aliases.
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
Retrieves the data stream lifecycle configuration of one or more 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
Retrieves information about one or more 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
Get index templates. Returns information about one or more index templates.
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_index_template.rb', line 37 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
Retrieves mapping definitions for one or more indices. For data streams, the API retrieves mappings for the stream’s backing indices.
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/get_mapping.rb', line 38 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 setting information for one or more indices. For data streams, returns setting information for the stream’s backing indices.
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 66 |
# File 'lib/elasticsearch-serverless/api/indices/get_settings.rb', line 41 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
Converts an index alias to a data stream. You must have a matching index template that is data stream enabled. The alias must meet the following criteria: The alias must have a write index; All indices for the alias must have a @timestamp field mapping of a date or date_nanos field type; The alias must not have any filters; The alias must not use custom routing. If successful, the request removes the alias and creates a data stream with the same name. The indices for the alias become hidden backing indices for the stream. The write index for the alias becomes the write index for the stream.
41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 |
# File 'lib/elasticsearch-serverless/api/indices/migrate_to_data_stream.rb', line 41 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
Performs one or more data stream modification actions in a single atomic operation.
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
Adds a data stream or index to 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
Update the data lifecycle of the specified 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
Create or update an index template. Index templates define settings, mappings, and aliases that can be applied automatically to new indices.
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/put_index_template.rb', line 37 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
Adds new fields to an existing data stream or index. You can also use this API to change the search settings of existing fields. For data streams, these changes are applied to all backing indices by default.
41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 |
# File 'lib/elasticsearch-serverless/api/indices/put_mapping.rb', line 41 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
Changes a dynamic index setting in real time. For data streams, index setting changes are applied to all backing indices by default.
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/put_settings.rb', line 41 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 |
#put_template(arguments = {}) ⇒ Object
Create or update an index template. Index templates define settings, mappings, and aliases that can be applied automatically to new indices.
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/put_template.rb', line 38 def put_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 = "_template/#{Utils.listify(_name)}" params = Utils.process_params(arguments) ElasticsearchServerless::API::Response.new( perform_request(method, path, params, body, headers) ) end |
#refresh(arguments = {}) ⇒ Object
A refresh makes recent operations performed on one or more indices available for search. For data streams, the API runs the refresh operation on the stream’s backing indices.
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/refresh.rb', line 36 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
Resolves the specified name(s) and/or index patterns for indices, aliases, and data streams. Multiple patterns and remote clusters are supported.
34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 |
# File 'lib/elasticsearch-serverless/api/indices/resolve_index.rb', line 34 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
Creates a new index for a data stream or index alias.
38 39 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/rollover.rb', line 38 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 an index. Returns the index configuration that would be applied to the specified index from an existing index template.
35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 |
# File 'lib/elasticsearch-serverless/api/indices/simulate_index_template.rb', line 35 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 an index template. Returns the index configuration that would be applied by a particular index template.
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/simulate_template.rb', line 37 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
Adds a data stream or index to an alias.
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
Validates 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 |