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
}