Method executeDeleteOperation

pkg/kube/object_patch/patch.go:264–307

(op *deleteOperation)

}

func (o *ObjectPatcher) executeDeleteOperation(op *deleteOperation) error {
	gvk, err := o.kubeClient.GroupVersionResource(op.apiVersion, op.kind)
	if err != nil {
		return err
	}

	log.Debug("Started Delete API call")
	err = o.kubeClient.Dynamic().
		Resource(gvk).
		Namespace(op.namespace).
		Delete(context.TODO(), op.name, metav1.DeleteOptions{PropagationPolicy: &op.deletionPropagation}, op.subresource)

	log.Debug("Finished Delete API call")
	if errors.IsNotFound(err) {
		return nil
	}

	if err != nil {
		return err
	}

	if op.deletionPropagation != metav1.DeletePropagationForeground {
		return nil
	}

	log.Debug("Waiting for object deletion")

	err = wait.PollUntilContextTimeout(context.TODO(), time.Second, 20*time.Second, false, func(ctx context.Context) (bool, error) {
		log.Debug("Started Get API call")
		_, err := o.kubeClient.Dynamic().
			Resource(gvk).
			Namespace(op.namespace).
			Get(ctx, op.name, metav1.GetOptions{})

		log.Debug("Finished Get API call")
		if errors.IsNotFound(err) {
			return true, nil
		}

		return false, err
	})

	return err
}