diff options
Diffstat (limited to 'cloud/pkg/edgecontroller/controller')
| -rw-r--r-- | cloud/pkg/edgecontroller/controller/upstream.go | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/cloud/pkg/edgecontroller/controller/upstream.go b/cloud/pkg/edgecontroller/controller/upstream.go index 07a133741..88a71cb45 100644 --- a/cloud/pkg/edgecontroller/controller/upstream.go +++ b/cloud/pkg/edgecontroller/controller/upstream.go @@ -1090,15 +1090,19 @@ func (uc *UpstreamController) deletePod() { } } + var resMsg *model.Message err = uc.kubeClient.CoreV1().Pods(namespace).Delete(context.Background(), name, deleteOptions) if err != nil && !errors.IsNotFound(err) && !strings.Contains(err.Error(), "The object might have been deleted and then recreated") { klog.Warningf("Failed to delete pod, namespace: %s, name: %s, err: %v", namespace, name, err) - continue + resMsg = model.NewMessage(msg.GetID()). + FillBody(err). + BuildRouter(modules.EdgeControllerModuleName, constants.GroupResource, msg.GetResource(), model.ResponseOperation) + } else { + resMsg = model.NewMessage(msg.GetID()). + FillBody(common.MessageSuccessfulContent). + BuildRouter(modules.EdgeControllerModuleName, constants.GroupResource, msg.GetResource(), model.ResponseOperation) } - resMsg := model.NewMessage(msg.GetID()). - FillBody(common.MessageSuccessfulContent). - BuildRouter(modules.EdgeControllerModuleName, constants.GroupResource, msg.GetResource(), model.ResponseOperation) if err = uc.messageLayer.Response(*resMsg); err != nil { klog.Errorf("Message: %s process failure, response failed with error: %v", msg.GetID(), err) continue |