Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 4 additions & 4 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion api_generator/Cargo.toml
Original file line number Diff line number Diff line change
@@ -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"
Expand Down
2 changes: 1 addition & 1 deletion elasticsearch/Cargo.toml
Original file line number Diff line number Diff line change
@@ -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"
Expand Down
1 change: 1 addition & 0 deletions elasticsearch/src/.generated.toml
Original file line number Diff line number Diff line change
Expand Up @@ -35,6 +35,7 @@ written = [
"snapshot.rs",
"sql.rs",
"ssl.rs",
"streams.rs",
"synonyms.rs",
"tasks.rs",
"text_structure.rs",
Expand Down
36 changes: 28 additions & 8 deletions elasticsearch/src/async_search.rs
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@
}
}
}
#[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,
Expand Down Expand Up @@ -184,7 +184,7 @@
}
}
}
#[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,
Expand Down Expand Up @@ -329,7 +329,7 @@
}
}
}
#[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,
Expand Down Expand Up @@ -462,7 +462,7 @@
}
}
}
#[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,
Expand All @@ -476,6 +476,7 @@
analyzer: Option<&'b str>,
batched_reduce_size: Option<i64>,
body: Option<B>,
ccs_minimize_roundtrips: Option<bool>,
default_operator: Option<DefaultOperator>,
df: Option<&'b str>,
docvalue_fields: Option<&'b [&'b str]>,
Expand All @@ -497,6 +498,7 @@
q: Option<&'b str>,
request_cache: Option<bool>,
request_timeout: Option<Duration>,
rest_total_hits_as_int: Option<bool>,
routing: Option<&'b [&'b str]>,
search_type: Option<SearchType>,
seq_no_primary_term: Option<bool>,
Expand Down Expand Up @@ -537,6 +539,7 @@
analyzer: None,
batched_reduce_size: None,
body: None,
ccs_minimize_roundtrips: None,
default_operator: None,
df: None,
docvalue_fields: None,
Expand All @@ -557,6 +560,7 @@
q: None,
request_cache: None,
request_timeout: None,
rest_total_hits_as_int: None,
routing: None,
search_type: None,
seq_no_primary_term: None,
Expand Down Expand Up @@ -635,6 +639,7 @@
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,
Expand All @@ -656,6 +661,7 @@
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,
Expand All @@ -677,6 +683,11 @@
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);
Expand Down Expand Up @@ -782,6 +793,11 @@
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);
Expand Down Expand Up @@ -898,6 +914,7 @@
analyze_wildcard: Option<bool>,
analyzer: Option<&'b str>,
batched_reduce_size: Option<i64>,
ccs_minimize_roundtrips: Option<bool>,
default_operator: Option<DefaultOperator>,
df: Option<&'b str>,
#[serde(serialize_with = "crate::client::serialize_coll_qs")]
Expand All @@ -920,6 +937,7 @@
pretty: Option<bool>,
q: Option<&'b str>,
request_cache: Option<bool>,
rest_total_hits_as_int: Option<bool>,
#[serde(serialize_with = "crate::client::serialize_coll_qs")]
routing: Option<&'b [&'b str]>,
search_type: Option<SearchType>,
Expand Down Expand Up @@ -953,6 +971,7 @@
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,
Expand All @@ -972,6 +991,7 @@
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,
Expand Down Expand Up @@ -1014,19 +1034,19 @@
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>,
Expand All @@ -1036,7 +1056,7 @@
}
impl Elasticsearch {
#[doc = "Creates a namespace client for AsyncSearch APIs"]
pub fn async_search(&self) -> AsyncSearch {

Check warning on line 1059 in elasticsearch/src/async_search.rs

View workflow job for this annotation

GitHub Actions / clippy

hiding a lifetime that's elided elsewhere is confusing

warning: hiding a lifetime that's elided elsewhere is confusing --> elasticsearch/src/async_search.rs:1059:25 | 1059 | pub fn async_search(&self) -> AsyncSearch { | ^^^^^ ----------- the same lifetime is hidden here | | | the lifetime is elided here | = help: the same lifetime is referred to in inconsistent ways, making the signature confusing = note: `#[warn(mismatched_lifetime_syntaxes)]` on by default help: use `'_` for type paths | 1059 | pub fn async_search(&self) -> AsyncSearch<'_> { | ++++
AsyncSearch::new(self.transport())
}
}
16 changes: 8 additions & 8 deletions elasticsearch/src/autoscaling.rs
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@
}
}
}
#[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,
Expand Down Expand Up @@ -199,7 +199,7 @@
}
}
}
#[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,
Expand Down Expand Up @@ -326,7 +326,7 @@
}
}
}
#[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,
Expand Down Expand Up @@ -453,7 +453,7 @@
}
}
}
#[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,
Expand Down Expand Up @@ -606,25 +606,25 @@
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>,
Expand All @@ -634,7 +634,7 @@
}
impl Elasticsearch {
#[doc = "Creates a namespace client for Autoscaling APIs"]
pub fn autoscaling(&self) -> Autoscaling {

Check warning on line 637 in elasticsearch/src/autoscaling.rs

View workflow job for this annotation

GitHub Actions / clippy

hiding a lifetime that's elided elsewhere is confusing

warning: hiding a lifetime that's elided elsewhere is confusing --> elasticsearch/src/autoscaling.rs:637:24 | 637 | pub fn autoscaling(&self) -> Autoscaling { | ^^^^^ ----------- the same lifetime is hidden here | | | the lifetime is elided here | = help: the same lifetime is referred to in inconsistent ways, making the signature confusing help: use `'_` for type paths | 637 | pub fn autoscaling(&self) -> Autoscaling<'_> { | ++++
Autoscaling::new(self.transport())
}
}
Loading
Loading