|
1 | | -use k8s_openapi::api::core::v1::Pod; |
| 1 | +use k8s_openapi::{api::core::v1::Pod, apimachinery::pkg::api::resource::Quantity}; |
2 | 2 | use kube::{ |
3 | 3 | api::{Api, DeleteParams, Patch, PatchParams, PostParams, ResourceExt}, |
4 | 4 | runtime::wait::{await_condition, conditions::is_pod_running}, |
@@ -87,25 +87,20 @@ async fn main() -> anyhow::Result<()> { |
87 | 87 | info!("Updated resources via patch: {:?}", container.resources); |
88 | 88 | } |
89 | 89 | } |
90 | | - Err(e) => { |
91 | | - error!("Failed to patch resize pod: {}", e); |
92 | | - } |
| 90 | + Err(e) => error!("Failed to patch resize pod: {}", e), |
93 | 91 | } |
94 | 92 |
|
95 | 93 | // Example 3: Using replace_resize |
96 | 94 | info!("Example 3: Using replace_resize method"); |
97 | 95 | let mut current_pod = pods.get_resize("resize-demo").await?; |
98 | 96 |
|
| 97 | + // Update memory request |
99 | 98 | if let Some(spec) = &mut current_pod.spec |
100 | 99 | && let Some(container) = spec.containers.get_mut(0) |
101 | 100 | && let Some(resources) = &mut container.resources |
102 | 101 | && let Some(requests) = &mut resources.requests |
103 | 102 | { |
104 | | - // Update memory request |
105 | | - requests.insert( |
106 | | - "memory".to_string(), |
107 | | - k8s_openapi::apimachinery::pkg::api::resource::Quantity("384Mi".to_string()), |
108 | | - ); |
| 103 | + requests.insert("memory".into(), Quantity("384Mi".into())); |
109 | 104 | } |
110 | 105 |
|
111 | 106 | match pods.replace_resize("resize-demo", &pp, ¤t_pod).await { |
|
0 commit comments