func()

in internal/controller/authproxyworkload_controller.go [396:417]


func (r *AuthProxyWorkloadReconciler) updateWorkloadStatus(ctx context.Context, resource *cloudsqlapi.AuthProxyWorkload) (matching []workload.Workload, retErr error) {

	matching, err := r.listWorkloads(ctx, resource.Spec.Workload, resource.GetNamespace())
	if err != nil {
		return nil, err
	}

	for _, wl := range matching {
		// update the status condition for a workload
		s := newStatus(wl)
		s.Conditions = replaceCondition(s.Conditions, &metav1.Condition{
			Type:               cloudsqlapi.ConditionWorkloadUpToDate,
			Status:             metav1.ConditionTrue,
			ObservedGeneration: resource.GetGeneration(),
			Reason:             cloudsqlapi.ReasonUpToDate,
			Message:            "No update needed for this workload",
		})
		resource.Status.WorkloadStatus = replaceStatus(resource.Status.WorkloadStatus, s)
	}

	return matching, nil
}