in controllers/dsworker_controller.go [289:302]
func (r *DSWorkerReconciler) deleteMember(ctx context.Context, pod *corev1.Pod, cluster *dsv1alpha1.DSWorker) error {
workerLogger.Info("begin delete pod", "pod name", pod.Name)
if err := r.Client.Delete(ctx, pod); err != nil && !apierrors.IsNotFound(err) {
return err
}
desired := cluster.DeepCopy()
desired.Spec.Replicas -= 1
if err := r.Status().Patch(ctx, desired, client.MergeFrom(cluster)); err != nil {
return err
}
return nil
}