INNER CODE UNIT · Go

observeVPA

streamnative/function-mesh · controllers/common.go:89

func observeVPA(ctx context.Context, r client.Reader, name types.NamespacedName, vpaSpec *v1alpha1.VPASpec,
	conditions map[v1alpha1.Component]v1alpha1.ResourceCondition) error {
	_, ok := conditions[v1alpha1.VPA]
	condition := v1alpha1.ResourceCondition{Condition: v1alpha1.VPAReady}
	if !ok {
		if vpaSpec != nil {
			condition.Status = metav1.ConditionFalse
			condition.Action = v1alpha1.Create
			conditions[v1alpha1.VPA] = condition
			return nil
		}
		// VPA is not enabled, skip further action
		return nil
	}

	vpa := &vpav1.VerticalPodAutoscaler{}
	err := r.Get(ctx, name, vpa)
	if err != nil {

View source record →