Skip to content

Commit eaa3b95

Browse files
committed
Generate code for 8.16.0
1 parent e6e2f02 commit eaa3b95

File tree

13 files changed

+1159
-72
lines changed

13 files changed

+1159
-72
lines changed

elasticsearch/src/cluster.rs

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -2457,9 +2457,9 @@ pub struct ClusterStats<'a, 'b> {
24572457
parts: ClusterStatsParts<'b>,
24582458
error_trace: Option<bool>,
24592459
filter_path: Option<&'b [&'b str]>,
2460-
flat_settings: Option<bool>,
24612460
headers: HeaderMap,
24622461
human: Option<bool>,
2462+
include_remotes: Option<bool>,
24632463
pretty: Option<bool>,
24642464
request_timeout: Option<Duration>,
24652465
source: Option<&'b str>,
@@ -2475,8 +2475,8 @@ impl<'a, 'b> ClusterStats<'a, 'b> {
24752475
headers,
24762476
error_trace: None,
24772477
filter_path: None,
2478-
flat_settings: None,
24792478
human: None,
2479+
include_remotes: None,
24802480
pretty: None,
24812481
request_timeout: None,
24822482
source: None,
@@ -2493,11 +2493,6 @@ impl<'a, 'b> ClusterStats<'a, 'b> {
24932493
self.filter_path = Some(filter_path);
24942494
self
24952495
}
2496-
#[doc = "Return settings in flat format (default: false)"]
2497-
pub fn flat_settings(mut self, flat_settings: bool) -> Self {
2498-
self.flat_settings = Some(flat_settings);
2499-
self
2500-
}
25012496
#[doc = "Adds a HTTP header"]
25022497
pub fn header(mut self, key: HeaderName, value: HeaderValue) -> Self {
25032498
self.headers.insert(key, value);
@@ -2508,6 +2503,11 @@ impl<'a, 'b> ClusterStats<'a, 'b> {
25082503
self.human = Some(human);
25092504
self
25102505
}
2506+
#[doc = "Include remote cluster data into the response (default: false)"]
2507+
pub fn include_remotes(mut self, include_remotes: bool) -> Self {
2508+
self.include_remotes = Some(include_remotes);
2509+
self
2510+
}
25112511
#[doc = "Pretty format the returned JSON response."]
25122512
pub fn pretty(mut self, pretty: bool) -> Self {
25132513
self.pretty = Some(pretty);
@@ -2541,17 +2541,17 @@ impl<'a, 'b> ClusterStats<'a, 'b> {
25412541
error_trace: Option<bool>,
25422542
#[serde(serialize_with = "crate::client::serialize_coll_qs")]
25432543
filter_path: Option<&'b [&'b str]>,
2544-
flat_settings: Option<bool>,
25452544
human: Option<bool>,
2545+
include_remotes: Option<bool>,
25462546
pretty: Option<bool>,
25472547
source: Option<&'b str>,
25482548
timeout: Option<&'b str>,
25492549
}
25502550
let query_params = QueryParams {
25512551
error_trace: self.error_trace,
25522552
filter_path: self.filter_path,
2553-
flat_settings: self.flat_settings,
25542553
human: self.human,
2554+
include_remotes: self.include_remotes,
25552555
pretty: self.pretty,
25562556
source: self.source,
25572557
timeout: self.timeout,

elasticsearch/src/http/transport.rs

Lines changed: 16 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,10 @@
1818
*/
1919
//! HTTP transport and connection components
2020
21-
#[cfg(all(target_arch = "wasm32", any(feature = "native-tls", feature = "rustls-tls")))]
21+
#[cfg(all(
22+
target_arch = "wasm32",
23+
any(feature = "native-tls", feature = "rustls-tls")
24+
))]
2225
compile_error!("TLS features are not compatible with the wasm target");
2326

2427
#[cfg(any(feature = "native-tls", feature = "rustls-tls"))]
@@ -481,8 +484,7 @@ impl Transport {
481484
headers: HeaderMap,
482485
query_string: Option<&Q>,
483486
body: Option<B>,
484-
#[allow(unused_variables)]
485-
timeout: Option<Duration>,
487+
#[allow(unused_variables)] timeout: Option<Duration>,
486488
) -> Result<reqwest::RequestBuilder, Error>
487489
where
488490
B: Body,
@@ -589,15 +591,17 @@ impl Transport {
589591
let connection = self.conn_pool.next();
590592

591593
// Build node info request
592-
let node_request = self.request_builder(
593-
&connection,
594-
Method::Get,
595-
"_nodes/http?filter_path=nodes.*.http",
596-
HeaderMap::default(),
597-
None::<&()>,
598-
None::<()>,
599-
None,
600-
).unwrap();
594+
let node_request = self
595+
.request_builder(
596+
&connection,
597+
Method::Get,
598+
"_nodes/http?filter_path=nodes.*.http",
599+
HeaderMap::default(),
600+
None::<&()>,
601+
None::<()>,
602+
None,
603+
)
604+
.unwrap();
601605

602606
let scheme = connection.url.scheme();
603607
let resp = node_request.send().await.unwrap();

0 commit comments

Comments
 (0)