in internal/controller/authproxyworkload_controller.go [517:537]
func (r *AuthProxyWorkloadReconciler) loadByLabelSelector(ctx context.Context, workloadSelector cloudsqlapi.WorkloadSelectorSpec, ns string) ([]workload.Workload, error) {
l := log.FromContext(ctx)
sel, err := workloadSelector.LabelsSelector()
if err != nil {
return nil, err
}
_, gk := schema.ParseKindArg(workloadSelector.Kind)
wl, err := workload.WorkloadListForKind(gk.Kind)
if err != nil {
return nil, err
}
err = r.List(ctx, wl.List(), client.InNamespace(ns), client.MatchingLabelsSelector{Selector: sel})
if err != nil {
l.Error(err, "Unable to list s for workloadSelector", "selector", sel)
return nil, err
}
return wl.Workloads(), nil
}