diff --git a/Cargo.lock b/Cargo.lock index 66151dd1..7394a42a 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -125,7 +125,7 @@ checksum = "b3d1d046238990b9cf5bcde22a3fb3584ee5cf65fb2765f454ed428c7a0063da" [[package]] name = "api_generator" -version = "8.18.0-alpha.1" +version = "8.19.0-alpha.1" dependencies = [ "Inflector", "anyhow", @@ -640,7 +640,7 @@ checksum = "60b1af1c220855b6ceac025d3f6ecdd2b7c4894bfe9cd9bda4fbb4bc7c0d4cf0" [[package]] name = "elasticsearch" -version = "8.18.0-alpha.1" +version = "8.19.0-alpha.1" dependencies = [ "axum", "base64", @@ -2844,7 +2844,7 @@ checksum = "9d422e8e38ec76e2f06ee439ccc765e9c6a9638b9e7c9f2e8255e4d41e8bd852" [[package]] name = "xtask" -version = "8.18.0-alpha.1" +version = "8.19.0-alpha.1" dependencies = [ "anyhow", "chrono", @@ -2869,7 +2869,7 @@ dependencies = [ [[package]] name = "yaml_test_runner" -version = "8.18.0-alpha.1" +version = "8.19.0-alpha.1" dependencies = [ "Inflector", "anyhow", diff --git a/api_generator/Cargo.toml b/api_generator/Cargo.toml index 31e37ece..7a7c54ea 100644 --- a/api_generator/Cargo.toml +++ b/api_generator/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "api_generator" -version = "8.18.0-alpha.1" +version = "8.19.0-alpha.1" publish = false description = "Generates source code for elasticsearch package, from the Elasticsearch REST API specs" repository = "https://github.com/elastic/elasticsearch-rs" diff --git a/elasticsearch/Cargo.toml b/elasticsearch/Cargo.toml index f818a70f..62c5c2e9 100644 --- a/elasticsearch/Cargo.toml +++ b/elasticsearch/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "elasticsearch" -version = "8.18.0-alpha.1" +version = "8.19.0-alpha.1" edition = "2018" authors = ["Elastic and Contributors"] description = "Official Elasticsearch Rust client" diff --git a/elasticsearch/src/.generated.toml b/elasticsearch/src/.generated.toml index d3de017d..6c780353 100644 --- a/elasticsearch/src/.generated.toml +++ b/elasticsearch/src/.generated.toml @@ -35,6 +35,7 @@ written = [ "snapshot.rs", "sql.rs", "ssl.rs", + "streams.rs", "synonyms.rs", "tasks.rs", "text_structure.rs", diff --git a/elasticsearch/src/async_search.rs b/elasticsearch/src/async_search.rs index c7e8830a..818cd2c9 100644 --- a/elasticsearch/src/async_search.rs +++ b/elasticsearch/src/async_search.rs @@ -66,7 +66,7 @@ impl<'b> AsyncSearchDeleteParts<'b> { } } } -#[doc = "Builder for the [Async Search Delete API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/async-search.html)\n\nDeletes an async search by ID. If the search is still running, the search request will be cancelled. Otherwise, the saved search results are deleted."] +#[doc = "Builder for the [Async Search Delete API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/async-search.html)\n\nDeletes an async search by ID. If the search is still running, the search request will be cancelled. Otherwise, the saved search results are deleted."] #[derive(Clone, Debug)] pub struct AsyncSearchDelete<'a, 'b> { transport: &'a Transport, @@ -184,7 +184,7 @@ impl<'b> AsyncSearchGetParts<'b> { } } } -#[doc = "Builder for the [Async Search Get API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/async-search.html)\n\nRetrieves the results of a previously submitted async search request given its ID."] +#[doc = "Builder for the [Async Search Get API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/async-search.html)\n\nRetrieves the results of a previously submitted async search request given its ID."] #[derive(Clone, Debug)] pub struct AsyncSearchGet<'a, 'b> { transport: &'a Transport, @@ -329,7 +329,7 @@ impl<'b> AsyncSearchStatusParts<'b> { } } } -#[doc = "Builder for the [Async Search Status API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/async-search.html)\n\nRetrieves the status of a previously submitted async search request given its ID."] +#[doc = "Builder for the [Async Search Status API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/async-search.html)\n\nRetrieves the status of a previously submitted async search request given its ID."] #[derive(Clone, Debug)] pub struct AsyncSearchStatus<'a, 'b> { transport: &'a Transport, @@ -462,7 +462,7 @@ impl<'b> AsyncSearchSubmitParts<'b> { } } } -#[doc = "Builder for the [Async Search Submit API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/async-search.html)\n\nExecutes a search request asynchronously."] +#[doc = "Builder for the [Async Search Submit API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/async-search.html)\n\nExecutes a search request asynchronously."] #[derive(Clone, Debug)] pub struct AsyncSearchSubmit<'a, 'b, B> { transport: &'a Transport, @@ -476,6 +476,7 @@ pub struct AsyncSearchSubmit<'a, 'b, B> { analyzer: Option<&'b str>, batched_reduce_size: Option, body: Option, + ccs_minimize_roundtrips: Option, default_operator: Option, df: Option<&'b str>, docvalue_fields: Option<&'b [&'b str]>, @@ -497,6 +498,7 @@ pub struct AsyncSearchSubmit<'a, 'b, B> { q: Option<&'b str>, request_cache: Option, request_timeout: Option, + rest_total_hits_as_int: Option, routing: Option<&'b [&'b str]>, search_type: Option, seq_no_primary_term: Option, @@ -537,6 +539,7 @@ where analyzer: None, batched_reduce_size: None, body: None, + ccs_minimize_roundtrips: None, default_operator: None, df: None, docvalue_fields: None, @@ -557,6 +560,7 @@ where q: None, request_cache: None, request_timeout: None, + rest_total_hits_as_int: None, routing: None, search_type: None, seq_no_primary_term: None, @@ -635,6 +639,7 @@ where analyze_wildcard: self.analyze_wildcard, analyzer: self.analyzer, batched_reduce_size: self.batched_reduce_size, + ccs_minimize_roundtrips: self.ccs_minimize_roundtrips, default_operator: self.default_operator, df: self.df, docvalue_fields: self.docvalue_fields, @@ -656,6 +661,7 @@ where q: self.q, request_cache: self.request_cache, request_timeout: self.request_timeout, + rest_total_hits_as_int: self.rest_total_hits_as_int, routing: self.routing, search_type: self.search_type, seq_no_primary_term: self.seq_no_primary_term, @@ -677,6 +683,11 @@ where wait_for_completion_timeout: self.wait_for_completion_timeout, } } + #[doc = "When doing a cross-cluster search, setting it to true may improve overall search latency, particularly when searching clusters with a large number of shards. However, when set to true, the progress of searches on the remote clusters will not be received until the search finishes on all clusters."] + pub fn ccs_minimize_roundtrips(mut self, ccs_minimize_roundtrips: bool) -> Self { + self.ccs_minimize_roundtrips = Some(ccs_minimize_roundtrips); + self + } #[doc = "The default operator for query string query (AND or OR)"] pub fn default_operator(mut self, default_operator: DefaultOperator) -> Self { self.default_operator = Some(default_operator); @@ -782,6 +793,11 @@ where self.request_timeout = Some(timeout); self } + #[doc = "Indicates whether hits.total should be rendered as an integer or an object in the rest search response"] + pub fn rest_total_hits_as_int(mut self, rest_total_hits_as_int: bool) -> Self { + self.rest_total_hits_as_int = Some(rest_total_hits_as_int); + self + } #[doc = "A comma-separated list of specific routing values"] pub fn routing(mut self, routing: &'b [&'b str]) -> Self { self.routing = Some(routing); @@ -898,6 +914,7 @@ where analyze_wildcard: Option, analyzer: Option<&'b str>, batched_reduce_size: Option, + ccs_minimize_roundtrips: Option, default_operator: Option, df: Option<&'b str>, #[serde(serialize_with = "crate::client::serialize_coll_qs")] @@ -920,6 +937,7 @@ where pretty: Option, q: Option<&'b str>, request_cache: Option, + rest_total_hits_as_int: Option, #[serde(serialize_with = "crate::client::serialize_coll_qs")] routing: Option<&'b [&'b str]>, search_type: Option, @@ -953,6 +971,7 @@ where analyze_wildcard: self.analyze_wildcard, analyzer: self.analyzer, batched_reduce_size: self.batched_reduce_size, + ccs_minimize_roundtrips: self.ccs_minimize_roundtrips, default_operator: self.default_operator, df: self.df, docvalue_fields: self.docvalue_fields, @@ -972,6 +991,7 @@ where pretty: self.pretty, q: self.q, request_cache: self.request_cache, + rest_total_hits_as_int: self.rest_total_hits_as_int, routing: self.routing, search_type: self.search_type, seq_no_primary_term: self.seq_no_primary_term, @@ -1014,19 +1034,19 @@ impl<'a> AsyncSearch<'a> { pub fn transport(&self) -> &Transport { self.transport } - #[doc = "[Async Search Delete API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/async-search.html)\n\nDeletes an async search by ID. If the search is still running, the search request will be cancelled. Otherwise, the saved search results are deleted."] + #[doc = "[Async Search Delete API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/async-search.html)\n\nDeletes an async search by ID. If the search is still running, the search request will be cancelled. Otherwise, the saved search results are deleted."] pub fn delete<'b>(&'a self, parts: AsyncSearchDeleteParts<'b>) -> AsyncSearchDelete<'a, 'b> { AsyncSearchDelete::new(self.transport(), parts) } - #[doc = "[Async Search Get API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/async-search.html)\n\nRetrieves the results of a previously submitted async search request given its ID."] + #[doc = "[Async Search Get API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/async-search.html)\n\nRetrieves the results of a previously submitted async search request given its ID."] pub fn get<'b>(&'a self, parts: AsyncSearchGetParts<'b>) -> AsyncSearchGet<'a, 'b> { AsyncSearchGet::new(self.transport(), parts) } - #[doc = "[Async Search Status API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/async-search.html)\n\nRetrieves the status of a previously submitted async search request given its ID."] + #[doc = "[Async Search Status API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/async-search.html)\n\nRetrieves the status of a previously submitted async search request given its ID."] pub fn status<'b>(&'a self, parts: AsyncSearchStatusParts<'b>) -> AsyncSearchStatus<'a, 'b> { AsyncSearchStatus::new(self.transport(), parts) } - #[doc = "[Async Search Submit API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/async-search.html)\n\nExecutes a search request asynchronously."] + #[doc = "[Async Search Submit API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/async-search.html)\n\nExecutes a search request asynchronously."] pub fn submit<'b>( &'a self, parts: AsyncSearchSubmitParts<'b>, diff --git a/elasticsearch/src/autoscaling.rs b/elasticsearch/src/autoscaling.rs index dfdec41b..28a11b75 100644 --- a/elasticsearch/src/autoscaling.rs +++ b/elasticsearch/src/autoscaling.rs @@ -66,7 +66,7 @@ impl<'b> AutoscalingDeleteAutoscalingPolicyParts<'b> { } } } -#[doc = "Builder for the [Autoscaling Delete Autoscaling Policy API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/autoscaling-delete-autoscaling-policy.html)\n\nDeletes an autoscaling policy. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported."] +#[doc = "Builder for the [Autoscaling Delete Autoscaling Policy API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/autoscaling-delete-autoscaling-policy.html)\n\nDeletes an autoscaling policy. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported."] #[derive(Clone, Debug)] pub struct AutoscalingDeleteAutoscalingPolicy<'a, 'b> { transport: &'a Transport, @@ -199,7 +199,7 @@ impl AutoscalingGetAutoscalingCapacityParts { } } } -#[doc = "Builder for the [Autoscaling Get Autoscaling Capacity API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/autoscaling-get-autoscaling-capacity.html)\n\nGets the current autoscaling capacity based on the configured autoscaling policy. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported."] +#[doc = "Builder for the [Autoscaling Get Autoscaling Capacity API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/autoscaling-get-autoscaling-capacity.html)\n\nGets the current autoscaling capacity based on the configured autoscaling policy. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported."] #[derive(Clone, Debug)] pub struct AutoscalingGetAutoscalingCapacity<'a, 'b> { transport: &'a Transport, @@ -326,7 +326,7 @@ impl<'b> AutoscalingGetAutoscalingPolicyParts<'b> { } } } -#[doc = "Builder for the [Autoscaling Get Autoscaling Policy API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/autoscaling-get-autoscaling-policy.html)\n\nRetrieves an autoscaling policy. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported."] +#[doc = "Builder for the [Autoscaling Get Autoscaling Policy API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/autoscaling-get-autoscaling-policy.html)\n\nRetrieves an autoscaling policy. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported."] #[derive(Clone, Debug)] pub struct AutoscalingGetAutoscalingPolicy<'a, 'b> { transport: &'a Transport, @@ -453,7 +453,7 @@ impl<'b> AutoscalingPutAutoscalingPolicyParts<'b> { } } } -#[doc = "Builder for the [Autoscaling Put Autoscaling Policy API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/autoscaling-put-autoscaling-policy.html)\n\nCreates a new autoscaling policy. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported."] +#[doc = "Builder for the [Autoscaling Put Autoscaling Policy API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/autoscaling-put-autoscaling-policy.html)\n\nCreates a new autoscaling policy. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported."] #[derive(Clone, Debug)] pub struct AutoscalingPutAutoscalingPolicy<'a, 'b, B> { transport: &'a Transport, @@ -606,25 +606,25 @@ impl<'a> Autoscaling<'a> { pub fn transport(&self) -> &Transport { self.transport } - #[doc = "[Autoscaling Delete Autoscaling Policy API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/autoscaling-delete-autoscaling-policy.html)\n\nDeletes an autoscaling policy. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported."] + #[doc = "[Autoscaling Delete Autoscaling Policy API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/autoscaling-delete-autoscaling-policy.html)\n\nDeletes an autoscaling policy. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported."] pub fn delete_autoscaling_policy<'b>( &'a self, parts: AutoscalingDeleteAutoscalingPolicyParts<'b>, ) -> AutoscalingDeleteAutoscalingPolicy<'a, 'b> { AutoscalingDeleteAutoscalingPolicy::new(self.transport(), parts) } - #[doc = "[Autoscaling Get Autoscaling Capacity API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/autoscaling-get-autoscaling-capacity.html)\n\nGets the current autoscaling capacity based on the configured autoscaling policy. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported."] + #[doc = "[Autoscaling Get Autoscaling Capacity API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/autoscaling-get-autoscaling-capacity.html)\n\nGets the current autoscaling capacity based on the configured autoscaling policy. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported."] pub fn get_autoscaling_capacity<'b>(&'a self) -> AutoscalingGetAutoscalingCapacity<'a, 'b> { AutoscalingGetAutoscalingCapacity::new(self.transport()) } - #[doc = "[Autoscaling Get Autoscaling Policy API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/autoscaling-get-autoscaling-policy.html)\n\nRetrieves an autoscaling policy. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported."] + #[doc = "[Autoscaling Get Autoscaling Policy API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/autoscaling-get-autoscaling-policy.html)\n\nRetrieves an autoscaling policy. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported."] pub fn get_autoscaling_policy<'b>( &'a self, parts: AutoscalingGetAutoscalingPolicyParts<'b>, ) -> AutoscalingGetAutoscalingPolicy<'a, 'b> { AutoscalingGetAutoscalingPolicy::new(self.transport(), parts) } - #[doc = "[Autoscaling Put Autoscaling Policy API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/autoscaling-put-autoscaling-policy.html)\n\nCreates a new autoscaling policy. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported."] + #[doc = "[Autoscaling Put Autoscaling Policy API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/autoscaling-put-autoscaling-policy.html)\n\nCreates a new autoscaling policy. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported."] pub fn put_autoscaling_policy<'b>( &'a self, parts: AutoscalingPutAutoscalingPolicyParts<'b>, diff --git a/elasticsearch/src/cat.rs b/elasticsearch/src/cat.rs index 9ea49dd4..96b45bfc 100644 --- a/elasticsearch/src/cat.rs +++ b/elasticsearch/src/cat.rs @@ -160,7 +160,7 @@ impl<'b> CatAliasesParts<'b> { } } } -#[doc = "Builder for the [Cat Aliases API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/cat-alias.html)\n\nShows information about currently configured aliases to indices including filter and routing infos."] +#[doc = "Builder for the [Cat Aliases API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/cat-alias.html)\n\nShows information about currently configured aliases to indices including filter and routing infos."] #[derive(Clone, Debug)] pub struct CatAliases<'a, 'b> { transport: &'a Transport, @@ -351,7 +351,7 @@ impl<'b> CatAllocationParts<'b> { } } } -#[doc = "Builder for the [Cat Allocation API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/cat-allocation.html)\n\nProvides a snapshot of how many shards are allocated to each data node and how much disk space they are using."] +#[doc = "Builder for the [Cat Allocation API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/cat-allocation.html)\n\nProvides a snapshot of how many shards are allocated to each data node and how much disk space they are using."] #[derive(Clone, Debug)] pub struct CatAllocation<'a, 'b> { transport: &'a Transport, @@ -548,7 +548,7 @@ impl<'b> CatComponentTemplatesParts<'b> { } } } -#[doc = "Builder for the [Cat Component Templates API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/cat-component-templates.html)\n\nReturns information about existing component_templates templates."] +#[doc = "Builder for the [Cat Component Templates API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/cat-component-templates.html)\n\nReturns information about existing component_templates templates."] #[derive(Clone, Debug)] pub struct CatComponentTemplates<'a, 'b> { transport: &'a Transport, @@ -738,7 +738,7 @@ impl<'b> CatCountParts<'b> { } } } -#[doc = "Builder for the [Cat Count API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/cat-count.html)\n\nProvides quick access to the document count of the entire cluster, or individual indices."] +#[doc = "Builder for the [Cat Count API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/cat-count.html)\n\nProvides quick access to the document count of the entire cluster, or individual indices."] #[derive(Clone, Debug)] pub struct CatCount<'a, 'b> { transport: &'a Transport, @@ -910,7 +910,7 @@ impl<'b> CatFielddataParts<'b> { } } } -#[doc = "Builder for the [Cat Fielddata API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/cat-fielddata.html)\n\nShows how much heap memory is currently being used by fielddata on every data node in the cluster."] +#[doc = "Builder for the [Cat Fielddata API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/cat-fielddata.html)\n\nShows how much heap memory is currently being used by fielddata on every data node in the cluster."] #[derive(Clone, Debug)] pub struct CatFielddata<'a, 'b> { transport: &'a Transport, @@ -1090,7 +1090,7 @@ impl CatHealthParts { } } } -#[doc = "Builder for the [Cat Health API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/cat-health.html)\n\nReturns a concise representation of the cluster health."] +#[doc = "Builder for the [Cat Health API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/cat-health.html)\n\nReturns a concise representation of the cluster health."] #[derive(Clone, Debug)] pub struct CatHealth<'a, 'b> { transport: &'a Transport, @@ -1269,7 +1269,7 @@ impl CatHelpParts { } } } -#[doc = "Builder for the [Cat Help API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/cat.html)\n\nReturns help for the Cat APIs."] +#[doc = "Builder for the [Cat Help API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/cat.html)\n\nReturns help for the Cat APIs."] #[derive(Clone, Debug)] pub struct CatHelp<'a, 'b> { transport: &'a Transport, @@ -1277,11 +1277,9 @@ pub struct CatHelp<'a, 'b> { error_trace: Option, filter_path: Option<&'b [&'b str]>, headers: HeaderMap, - help: Option, human: Option, pretty: Option, request_timeout: Option, - s: Option<&'b [&'b str]>, source: Option<&'b str>, } impl<'a, 'b> CatHelp<'a, 'b> { @@ -1296,11 +1294,9 @@ impl<'a, 'b> CatHelp<'a, 'b> { headers, error_trace: None, filter_path: None, - help: None, human: None, pretty: None, request_timeout: None, - s: None, source: None, } } @@ -1319,11 +1315,6 @@ impl<'a, 'b> CatHelp<'a, 'b> { self.headers.insert(key, value); self } - #[doc = "Return help information"] - pub fn help(mut self, help: bool) -> Self { - self.help = Some(help); - self - } #[doc = "Return human readable values for statistics."] pub fn human(mut self, human: bool) -> Self { self.human = Some(human); @@ -1339,11 +1330,6 @@ impl<'a, 'b> CatHelp<'a, 'b> { self.request_timeout = Some(timeout); self } - #[doc = "Comma-separated list of column names or column aliases to sort by"] - pub fn s(mut self, s: &'b [&'b str]) -> Self { - self.s = Some(s); - self - } #[doc = "The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests."] pub fn source(mut self, source: &'b str) -> Self { self.source = Some(source); @@ -1362,20 +1348,15 @@ impl<'a, 'b> CatHelp<'a, 'b> { error_trace: Option, #[serde(serialize_with = "crate::client::serialize_coll_qs")] filter_path: Option<&'b [&'b str]>, - help: Option, human: Option, pretty: Option, - #[serde(serialize_with = "crate::client::serialize_coll_qs")] - s: Option<&'b [&'b str]>, source: Option<&'b str>, } let query_params = QueryParams { error_trace: self.error_trace, filter_path: self.filter_path, - help: self.help, human: self.human, pretty: self.pretty, - s: self.s, source: self.source, }; Some(query_params) @@ -1413,7 +1394,7 @@ impl<'b> CatIndicesParts<'b> { } } } -#[doc = "Builder for the [Cat Indices API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/cat-indices.html)\n\nReturns information about indices: number of primaries and replicas, document counts, disk size, ..."] +#[doc = "Builder for the [Cat Indices API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/cat-indices.html)\n\nReturns information about indices: number of primaries and replicas, document counts, disk size, ..."] #[derive(Clone, Debug)] pub struct CatIndices<'a, 'b> { transport: &'a Transport, @@ -1638,7 +1619,7 @@ impl CatMasterParts { } } } -#[doc = "Builder for the [Cat Master API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/cat-master.html)\n\nReturns information about the master node."] +#[doc = "Builder for the [Cat Master API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/cat-master.html)\n\nReturns information about the master node."] #[derive(Clone, Debug)] pub struct CatMaster<'a, 'b> { transport: &'a Transport, @@ -1826,7 +1807,7 @@ impl<'b> CatMlDataFrameAnalyticsParts<'b> { } } } -#[doc = "Builder for the [Cat Ml Data Frame Analytics API](http://www.elastic.co/guide/en/elasticsearch/reference/8.15/cat-dfanalytics.html)\n\nGets configuration and usage information about data frame analytics jobs."] +#[doc = "Builder for the [Cat Ml Data Frame Analytics API](http://www.elastic.co/guide/en/elasticsearch/reference/8.19/cat-dfanalytics.html)\n\nGets configuration and usage information about data frame analytics jobs."] #[derive(Clone, Debug)] pub struct CatMlDataFrameAnalytics<'a, 'b> { transport: &'a Transport, @@ -2024,7 +2005,7 @@ impl<'b> CatMlDatafeedsParts<'b> { } } } -#[doc = "Builder for the [Cat Ml Datafeeds API](http://www.elastic.co/guide/en/elasticsearch/reference/8.15/cat-datafeeds.html)\n\nGets configuration and usage information about datafeeds."] +#[doc = "Builder for the [Cat Ml Datafeeds API](http://www.elastic.co/guide/en/elasticsearch/reference/8.19/cat-datafeeds.html)\n\nGets configuration and usage information about datafeeds."] #[derive(Clone, Debug)] pub struct CatMlDatafeeds<'a, 'b> { transport: &'a Transport, @@ -2213,7 +2194,7 @@ impl<'b> CatMlJobsParts<'b> { } } } -#[doc = "Builder for the [Cat Ml Jobs API](http://www.elastic.co/guide/en/elasticsearch/reference/8.15/cat-anomaly-detectors.html)\n\nGets configuration and usage information about anomaly detection jobs."] +#[doc = "Builder for the [Cat Ml Jobs API](http://www.elastic.co/guide/en/elasticsearch/reference/8.19/cat-anomaly-detectors.html)\n\nGets configuration and usage information about anomaly detection jobs."] #[derive(Clone, Debug)] pub struct CatMlJobs<'a, 'b> { transport: &'a Transport, @@ -2411,7 +2392,7 @@ impl<'b> CatMlTrainedModelsParts<'b> { } } } -#[doc = "Builder for the [Cat Ml Trained Models API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/cat-trained-model.html)\n\nGets configuration and usage information about inference trained models."] +#[doc = "Builder for the [Cat Ml Trained Models API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/cat-trained-model.html)\n\nGets configuration and usage information about inference trained models."] #[derive(Clone, Debug)] pub struct CatMlTrainedModels<'a, 'b> { transport: &'a Transport, @@ -2617,7 +2598,7 @@ impl CatNodeattrsParts { } } } -#[doc = "Builder for the [Cat Nodeattrs API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/cat-nodeattrs.html)\n\nReturns information about custom node attributes."] +#[doc = "Builder for the [Cat Nodeattrs API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/cat-nodeattrs.html)\n\nReturns information about custom node attributes."] #[derive(Clone, Debug)] pub struct CatNodeattrs<'a, 'b> { transport: &'a Transport, @@ -2796,7 +2777,7 @@ impl CatNodesParts { } } } -#[doc = "Builder for the [Cat Nodes API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/cat-nodes.html)\n\nReturns basic statistics about performance of cluster nodes."] +#[doc = "Builder for the [Cat Nodes API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/cat-nodes.html)\n\nReturns basic statistics about performance of cluster nodes."] #[derive(Clone, Debug)] pub struct CatNodes<'a, 'b> { transport: &'a Transport, @@ -3002,7 +2983,7 @@ impl CatPendingTasksParts { } } } -#[doc = "Builder for the [Cat Pending Tasks API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/cat-pending-tasks.html)\n\nReturns a concise representation of the cluster pending tasks."] +#[doc = "Builder for the [Cat Pending Tasks API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/cat-pending-tasks.html)\n\nReturns a concise representation of the cluster pending tasks."] #[derive(Clone, Debug)] pub struct CatPendingTasks<'a, 'b> { transport: &'a Transport, @@ -3190,7 +3171,7 @@ impl CatPluginsParts { } } } -#[doc = "Builder for the [Cat Plugins API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/cat-plugins.html)\n\nReturns information about installed plugins across nodes node."] +#[doc = "Builder for the [Cat Plugins API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/cat-plugins.html)\n\nReturns information about installed plugins across nodes node."] #[derive(Clone, Debug)] pub struct CatPlugins<'a, 'b> { transport: &'a Transport, @@ -3389,7 +3370,7 @@ impl<'b> CatRecoveryParts<'b> { } } } -#[doc = "Builder for the [Cat Recovery API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/cat-recovery.html)\n\nReturns information about index shard recoveries, both on-going completed."] +#[doc = "Builder for the [Cat Recovery API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/cat-recovery.html)\n\nReturns information about index shard recoveries, both on-going completed."] #[derive(Clone, Debug)] pub struct CatRecovery<'a, 'b> { transport: &'a Transport, @@ -3596,7 +3577,7 @@ impl CatRepositoriesParts { } } } -#[doc = "Builder for the [Cat Repositories API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/cat-repositories.html)\n\nReturns information about snapshot repositories registered in the cluster."] +#[doc = "Builder for the [Cat Repositories API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/cat-repositories.html)\n\nReturns information about snapshot repositories registered in the cluster."] #[derive(Clone, Debug)] pub struct CatRepositories<'a, 'b> { transport: &'a Transport, @@ -3786,7 +3767,7 @@ impl<'b> CatSegmentsParts<'b> { } } } -#[doc = "Builder for the [Cat Segments API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/cat-segments.html)\n\nProvides low-level information about the segments in the shards of an index."] +#[doc = "Builder for the [Cat Segments API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/cat-segments.html)\n\nProvides low-level information about the segments in the shards of an index."] #[derive(Clone, Debug)] pub struct CatSegments<'a, 'b> { transport: &'a Transport, @@ -3799,6 +3780,8 @@ pub struct CatSegments<'a, 'b> { headers: HeaderMap, help: Option, human: Option, + local: Option, + master_timeout: Option<&'b str>, pretty: Option, request_timeout: Option, s: Option<&'b [&'b str]>, @@ -3822,6 +3805,8 @@ impl<'a, 'b> CatSegments<'a, 'b> { h: None, help: None, human: None, + local: None, + master_timeout: None, pretty: None, request_timeout: None, s: None, @@ -3869,6 +3854,16 @@ impl<'a, 'b> CatSegments<'a, 'b> { self.human = Some(human); self } + #[doc = "Return local information, do not retrieve the state from master node (default: false)"] + pub fn local(mut self, local: bool) -> Self { + self.local = Some(local); + self + } + #[doc = "Explicit operation timeout for connection to master node"] + pub fn master_timeout(mut self, master_timeout: &'b str) -> Self { + self.master_timeout = Some(master_timeout); + self + } #[doc = "Pretty format the returned JSON response."] pub fn pretty(mut self, pretty: bool) -> Self { self.pretty = Some(pretty); @@ -3913,6 +3908,8 @@ impl<'a, 'b> CatSegments<'a, 'b> { h: Option<&'b [&'b str]>, help: Option, human: Option, + local: Option, + master_timeout: Option<&'b str>, pretty: Option, #[serde(serialize_with = "crate::client::serialize_coll_qs")] s: Option<&'b [&'b str]>, @@ -3927,6 +3924,8 @@ impl<'a, 'b> CatSegments<'a, 'b> { h: self.h, help: self.help, human: self.human, + local: self.local, + master_timeout: self.master_timeout, pretty: self.pretty, s: self.s, source: self.source, @@ -3967,7 +3966,7 @@ impl<'b> CatShardsParts<'b> { } } } -#[doc = "Builder for the [Cat Shards API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/cat-shards.html)\n\nProvides a detailed view of shard allocation on nodes."] +#[doc = "Builder for the [Cat Shards API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/cat-shards.html)\n\nProvides a detailed view of shard allocation on nodes."] #[derive(Clone, Debug)] pub struct CatShards<'a, 'b> { transport: &'a Transport, @@ -4166,7 +4165,7 @@ impl<'b> CatSnapshotsParts<'b> { } } } -#[doc = "Builder for the [Cat Snapshots API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/cat-snapshots.html)\n\nReturns all snapshots in a specific repository."] +#[doc = "Builder for the [Cat Snapshots API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/cat-snapshots.html)\n\nReturns all snapshots in a specific repository."] #[derive(Clone, Debug)] pub struct CatSnapshots<'a, 'b> { transport: &'a Transport, @@ -4356,7 +4355,7 @@ impl CatTasksParts { } } } -#[doc = "Builder for the [Cat Tasks API](https://www.elastic.co/guide/en/elasticsearch/reference/8.15/tasks.html)\n\nReturns information about the tasks currently executing on one or more nodes in the cluster."] +#[doc = "Builder for the [Cat Tasks API](https://www.elastic.co/guide/en/elasticsearch/reference/8.19/tasks.html)\n\nReturns information about the tasks currently executing on one or more nodes in the cluster."] #[doc = " \n# Optional, experimental\nThis requires the `experimental-apis` feature. Can have breaking changes in future\nversions or might even be removed entirely.\n "] #[cfg(feature = "experimental-apis")] #[derive(Clone, Debug)] @@ -4379,7 +4378,9 @@ pub struct CatTasks<'a, 'b> { s: Option<&'b [&'b str]>, source: Option<&'b str>, time: Option