how to restart deployment?

[vCassius]

this is my code,but can't run, when i do &Patch::Apply(&d),borrow of partially moved value: d [E0382] value borrowed here after partial move Note: partial move occurs because value has type DeploymentSpec, which does not implement the Copy trait

pub async fn restart(req: RestartParam) -> anyhow::Result<String> {
    let cli = match get_kubernetes_client(req.env.clone()).await {
        Ok(c) => c,
        Err(e) => return Err(anyhow!("fail to get kubernetes client,err: {e}")),
    };
    let deployment: Api<Deployment> = Api::namespaced(cli, req.namespace.clone().as_str());
    match deployment.get(req.name.clone().as_str()).await {
        Ok(d) => match d.spec {
            None => return Err(anyhow!("fail to get deployment spec")),
            Some(mut spec) => {
                let Some(paused) = spec.paused else{
                        return Err(anyhow!("fail to get deployment spec"))
                    };
                if paused {
                    return Err(anyhow!(
                        "restart request instance deploy: {} paused",
                        req.name.clone()
                    ));
                }
                let utc = chrono::Utc::now();
                let now = utc.with_timezone(&chrono_tz::Asia::Shanghai);
                match spec.template.metadata {
                    None => {
                        let mut annotations = BTreeMap::new();
                        annotations.insert(
                            "kubectl.kubernetes.io/restartedAt".to_string(),
                            now.time().to_string(),
                        );
                        spec.template.metadata = Some(ObjectMeta {
                            annotations: Some(annotations),
                            cluster_name: None,
                            creation_timestamp: None,
                            deletion_grace_period_seconds: None,
                            deletion_timestamp: None,
                            finalizers: None,
                            generate_name: None,
                            generation: None,
                            labels: None,
                            managed_fields: None,
                            name: None,
                            namespace: None,
                            owner_references: None,
                            resource_version: None,
                            self_link: None,
                            uid: None,
                        });
                    }
                    Some(mut metadata) => match metadata.annotations {
                        None => {
                            let mut annotations = BTreeMap::new();
                            annotations.insert(
                                "kubectl.kubernetes.io/restartedAt".to_string(),
                                now.time().to_string(),
                            );
                            metadata.annotations = Some(annotations);
                            match deployment
                                .patch(
                                    req.name.clone().as_str(),
                                    &PatchParams::default(),
                                    &Patch::Apply(&d),
                                )
                                .await
                            {
                                Ok(_) => {}
                                Err(_) => {}
                            }
                        }
                        Some(mut a) => {
                            a.insert(
                                "kubectl.kubernetes.io/restartedAt".to_string(),
                                now.time().to_string(),
                            );
                        }
                    },
                }
            }
        },
        Err(e) => return Err(anyhow!("fail to get deployment,err: {e}")),
    };
    Ok(format!(
        "restart deployment: {} with env: {} namespace: {} succeed",
        req.name, req.env, req.namespace
    ))
}

[clux]

Didn't look too deeply at this, but this general error is typically either forces you to propagate ref or & on match expressions everywhere (like on match &metadata.annotations), or do a big .clone() (which is derived) somewhere.

Also, FYI: Api::restart which ends up sending a kubectl style annotation update

[vCassius]

thx guy.i have done this problem.and first know Api:restart!~

[nightkr]

As a side note, patch writes (including server-side apply) should only write the fields that you actually want to update. If you want to read-modify-write then use replace instead.

[vCassius]

thx!~ another question, any metrics api to get nodes or pods metrics info?