in controllers/dsworker_controller.go [189:201]
func (r *DSWorkerReconciler) ensureMembers(ctx context.Context, cluster *dsv1alpha1.DSWorker) (bool, error) {
pms, err := r.podMemberSet(ctx, cluster)
if err != nil {
return true, err
}
if len(pms) > 0 {
return !allMembersHealth(pms), nil
} else {
return false, nil
}
}