deleteResource deletes a pod
(ctx context.Context, pod *corev1.Pod)
| 171 | |
| 172 | // deleteResource deletes a pod |
| 173 | func (c *PodController) deleteResource(ctx context.Context, pod *corev1.Pod) error { |
| 174 | logger := log.FromContext(ctx) |
| 175 | logger = logger.With( |
| 176 | "pod", log.KObj(pod), |
| 177 | "node", pod.Spec.NodeName, |
| 178 | ) |
| 179 | |
| 180 | err := c.typedClient.CoreV1().Pods(pod.Namespace).Delete(ctx, pod.Name, deleteOpt) |
| 181 | if err != nil { |
| 182 | return err |
| 183 | } |
| 184 | |
| 185 | logger.Info("Delete pod") |
| 186 | return nil |
| 187 | } |
| 188 | |
| 189 | // preprocessWorker receives the resource from the preprocessChan and preprocess it |
| 190 | func (c *PodController) preprocessWorker(ctx context.Context) { |