From 09c38cede1bc3d4f09e7c4a374b718b411f77cf1 Mon Sep 17 00:00:00 2001 From: Shelley-BaoYue Date: Fri, 22 Sep 2023 16:48:24 +0800 Subject: fix remove pod failed Signed-off-by: Shelley-BaoYue --- edge/pkg/edged/edged.go | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/edge/pkg/edged/edged.go b/edge/pkg/edged/edged.go index 172aefe05..16e422055 100644 --- a/edge/pkg/edged/edged.go +++ b/edge/pkg/edged/edged.go @@ -288,15 +288,16 @@ func (e *edged) handlePod(op string, content []byte, updatesChan chan<- interfac pods = append(pods, &pod) if filterPodByNodeName(&pod, e.nodeName) { + var podOp kubelettypes.PodOperation switch op { - case model.InsertOperation: - klog.V(4).InfoS("Receive message of adding new pods", "pods", klog.KObjs(pods)) - case model.UpdateOperation: - klog.V(4).InfoS("Receive message of updating pods", "pods", klog.KObjs(pods)) + case model.InsertOperation, model.UpdateOperation: + klog.V(4).InfoS("Receive message of add/update pods", "operation", op, "pods", klog.KObjs(pods)) + podOp = kubelettypes.UPDATE case model.DeleteOperation: klog.V(4).InfoS("Receive message of deleting pods", "pods", klog.KObjs(pods)) + podOp = kubelettypes.REMOVE } - updates := &kubelettypes.PodUpdate{Op: kubelettypes.UPDATE, Pods: pods, Source: kubelettypes.ApiserverSource} + updates := &kubelettypes.PodUpdate{Op: podOp, Pods: pods, Source: kubelettypes.ApiserverSource} updatesChan <- *updates } -- cgit v1.2.3