Почему client.Update(...) игнорирует не примитивные значения?

Question

Я пытаюсь изменить спецификацию не принадлежащих объекту как часть Reconcile моего пользовательского ресурса, но кажется, что он игнорирует любые поля, которые не являются примитивами. Я использую контроллер во время выполнения.

Я понял, так как он работал только с примитивами, может быть, это проблема, связанная с DeepCopy. Однако его удаление не решило проблему, и я прочитал, что любые обновления на объектах должны быть на глубоких копиях, чтобы не испортить кэш.

Я тоже пробовал настройку client.FieldOwner(...) так как он говорит, что это требуется для обновлений, которые выполняются на стороне сервера. Я не был уверен, что установить его, поэтому я сделал это req.NamespacedName.String(), Это тоже не сработало.

Вот цикл Reconcile для моего контроллера:

func (r *MyCustomObjectReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error) {
    // ...

    var myCustomObject customv1.MyCustomObject
    if err := r.Get(ctx, req.NamespacedName, &myCustomObject); err != nil {
        log.Error(err, "unable to fetch ReleaseDefinition")
        return ctrl.Result{}, client.IgnoreNotFound(err)
    }

    // ...

    deployList := &kappsv1.DeploymentList{}
    labels := map[string]string{
        "mylabel": myCustomObject.Name,
    }
    if err := r.List(ctx, deployList, client.MatchingLabels(labels)); err != nil {
        log.Error(err, "unable to fetch Deployments")
        return ctrl.Result{}, err
    }

    // make a deep copy to avoid messing up the cache (used by other controllers)
    myCustomObjectSpec := myCustomObject.Spec.DeepCopy()

    // the two fields of my CRD that affect the Deployments
    port := myCustomObjectSpec.Port // type: *int32
    customenv := myCustomObjectSpec.CustomEnv // type: map[string]string

    for _, dep := range deployList.Items {
        newDeploy := dep.DeepCopy() // already returns a pointer

        // Do these things:
        // 1. replace first container's containerPort with myCustomObjectSpec.Port
        // 2. replace first container's Env with values from myCustomObjectSpec.CustomEnv
                // 3. Update the Deployment

        container := newDeploy.Spec.Template.Spec.Containers[0]

        // 1. Replace container's port
        container.Ports[0].ContainerPort = *port

        envVars := make([]kcorev1.EnvVar, 0, len(customenv))
        for key, val := range customenv {
            envVars = append(envVars, kcorev1.EnvVar{
                Name:  key,
                Value: val,
            })
        }

        // 2. Replace container's Env variables
        container.Env = envVars

        // 3. Perform update for deployment (port works, env gets ignored)
        if err := r.Update(ctx, newDeploy); err != nil {
            log.Error(err, "unable to update deployment", "deployment", dep.Name)
            return ctrl.Result{}, err
        }
    }
    return ctrl.Result{}, nil
}

Спецификация для моего CRD выглядит так:

// MyCustomObjectSpec defines the desired state of MyCustomObject
type MyCustomObjectSpec struct {
    // CustomEnv is a list of environment variables to set in the containers.
    // +optional
    CustomEnv map[string]string `json:"customEnv,omitempty"`

    // Port is the port that the backend container is listening on.
    // +optional
    Port *int32 `json:"port,omitempty"`
}

Я ожидал, что когда я kubectl apply новый CR с изменениями в полях Port и CustomEnv, он будет изменять развертывания, как описано в Reconcile, Тем не менее, только порт обновляется, и изменения в контейнере Env игнорируются

Answer 1

Проблема заключалась в том, что мне нужен указатель на контейнер, который я модифицировал.

Делать это вместо этого работало:

container := &newDeploy.Spec.Template.Spec.Containers[0]