diff options
Diffstat (limited to 'edge/pkg/edged/edged.go')
| -rw-r--r-- | edge/pkg/edged/edged.go | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/edge/pkg/edged/edged.go b/edge/pkg/edged/edged.go index ef7fcd225..c300949c2 100644 --- a/edge/pkg/edged/edged.go +++ b/edge/pkg/edged/edged.go @@ -302,15 +302,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 } |