Verify we can use let-chains

after bumping image versions on e2e

Signed-off-by: clux <[email protected]>

Author: clux

examples/pod_resize.rs

@@ -1,8 +1,8 @@
 use k8s_openapi::api::core::v1::Pod;
 use kube::{
+    Client,
     api::{Api, DeleteParams, Patch, PatchParams, PostParams, ResourceExt},
     runtime::wait::{await_condition, conditions::is_pod_running},
-    Client,
 };
 use tracing::*;
 
@@ -48,10 +48,10 @@ async fn main() -> anyhow::Result<()> {
     // Example 1: Using get_resize to view current state
     info!("Example 1: Getting pod resize subresource");
     let current = pods.get_resize("resize-demo").await?;
-    if let Some(spec) = &current.spec {
-        if let Some(container) = spec.containers.first() {
-            info!("Current resources: {:?}", container.resources);
-        }
+    if let Some(spec) = &current.spec
+        && let Some(container) = spec.containers.first()
+    {
+        info!("Current resources: {:?}", container.resources);
     }
 
     // Example 2: Using patch_resize to update resources
@@ -81,10 +81,10 @@ async fn main() -> anyhow::Result<()> {
     {
         Ok(resized) => {
             info!("Successfully patched pod: {}", resized.name_any());
-            if let Some(spec) = resized.spec {
-                if let Some(container) = spec.containers.first() {
-                    info!("Updated resources via patch: {:?}", container.resources);
-                }
+            if let Some(spec) = resized.spec
+                && let Some(container) = spec.containers.first()
+            {
+                info!("Updated resources via patch: {:?}", container.resources);
             }
         }
         Err(e) => {
@@ -96,27 +96,25 @@ async fn main() -> anyhow::Result<()> {
     info!("Example 3: Using replace_resize method");
     let mut current_pod = pods.get_resize("resize-demo").await?;
 
-    if let Some(spec) = &mut current_pod.spec {
-        if let Some(container) = spec.containers.get_mut(0) {
-            if let Some(resources) = &mut container.resources {
-                // Update memory request
-                if let Some(requests) = &mut resources.requests {
-                    requests.insert(
-                        "memory".to_string(),
-                        k8s_openapi::apimachinery::pkg::api::resource::Quantity("384Mi".to_string()),
-                    );
-                }
-            }
-        }
+    if let Some(spec) = &mut current_pod.spec
+        && let Some(container) = spec.containers.get_mut(0)
+        && let Some(resources) = &mut container.resources
+        && let Some(requests) = &mut resources.requests
+    {
+        // Update memory request
+        requests.insert(
+            "memory".to_string(),
+            k8s_openapi::apimachinery::pkg::api::resource::Quantity("384Mi".to_string()),
+        );
     }
 
     match pods.replace_resize("resize-demo", &pp, &current_pod).await {
         Ok(resized) => {
             info!("Pod resized via replace: {}", resized.name_any());
-            if let Some(spec) = resized.spec {
-                if let Some(container) = spec.containers.first() {
-                    info!("Final resources via replace: {:?}", container.resources);
-                }
+            if let Some(spec) = resized.spec
+                && let Some(container) = spec.containers.first()
+            {
+                info!("Final resources via replace: {:?}", container.resources);
             }
         }
         Err(e) => error!("Failed to replace_resize: {}", e),

kube-client/src/api/subresource.rs

@@ -1,10 +1,10 @@
 use futures::AsyncBufRead;
-use serde::{de::DeserializeOwned, Serialize};
+use serde::{Serialize, de::DeserializeOwned};
 use std::fmt::Debug;
 
 use crate::{
-    api::{Api, Patch, PatchParams, PostParams},
     Error, Result,
+    api::{Api, Patch, PatchParams, PostParams},
 };
 
 use kube_core::response::Status;
@@ -16,8 +16,10 @@ pub use kube_core::subresource::AttachParams;
 
 pub use k8s_openapi::api::autoscaling::v1::{Scale, ScaleSpec, ScaleStatus};
 
-#[cfg(feature = "ws")] use crate::api::portforward::Portforwarder;
-#[cfg(feature = "ws")] use crate::api::remote_command::AttachedProcess;
+#[cfg(feature = "ws")]
+use crate::api::portforward::Portforwarder;
+#[cfg(feature = "ws")]
+use crate::api::remote_command::AttachedProcess;
 
 /// Methods for [scale subresource](https://kubernetes.io/docs/tasks/access-kubernetes-api/custom-resources/custom-resource-definitions/#scale-subresource).
 impl<K> Api<K>
@@ -399,13 +401,11 @@ k8s_openapi::k8s_if_ge_1_33! {
         /// let mut pod = pods.get("mypod").await?;
         ///
         /// // Modify resource requirements
-        /// if let Some(spec) = &mut pod.spec {
-        ///     if let Some(container) = spec.containers.get_mut(0) {
-        ///         if let Some(resources) = &mut container.resources {
-        ///             // Update CPU/memory limits or requests
-        ///             // ...
-        ///         }
-        ///     }
+        /// if let Some(spec) = &mut pod.spec &&
+        ///    let Some(container) = spec.containers.get_mut(0) &&
+        ///    let Some(resources) = &mut container.resources {
+        ///         // Update CPU/memory limits or requests
+        ///         // ...
         /// }
         ///
         /// pods.replace_resize("mypod", &pp, &pod).await?;