diff options
| author | Shelley-BaoYue <baoyue2@huawei.com> | 2023-09-20 09:58:42 +0800 |
|---|---|---|
| committer | Shelley-BaoYue <baoyue2@huawei.com> | 2023-10-08 10:43:48 +0800 |
| commit | 10b33bf8accddaf093470e6f97929af9d5896b1e (patch) | |
| tree | 2e6627d9a2d330cb46098d7bfa0324a18104db69 /cloud | |
| parent | add support static in kubeedge (diff) | |
| download | kubeedge-10b33bf8accddaf093470e6f97929af9d5896b1e.tar.gz | |
update resourcetype pod
Signed-off-by: Shelley-BaoYue <baoyue2@huawei.com>
Diffstat (limited to 'cloud')
| -rw-r--r-- | cloud/pkg/cloudhub/dispatcher/message_dispatcher.go | 2 | ||||
| -rw-r--r-- | cloud/pkg/edgecontroller/controller/upstream.go | 10 |
2 files changed, 6 insertions, 6 deletions
diff --git a/cloud/pkg/cloudhub/dispatcher/message_dispatcher.go b/cloud/pkg/cloudhub/dispatcher/message_dispatcher.go index 8dc837c7c..dd953fa57 100644 --- a/cloud/pkg/cloudhub/dispatcher/message_dispatcher.go +++ b/cloud/pkg/cloudhub/dispatcher/message_dispatcher.go @@ -468,7 +468,7 @@ func noAckRequired(msg *beehivemodel.Message) bool { resourceType == beehivemodel.ResourceTypeNodePatch || resourceType == beehivemodel.ResourceTypePodPatch || resourceType == beehivemodel.ResourceTypePodStatus || - resourceType == beehivemodel.ResourceTypeCreatePod { + (resourceType == beehivemodel.ResourceTypePod && msg.GetOperation() == beehivemodel.ResponseOperation) { return true } } diff --git a/cloud/pkg/edgecontroller/controller/upstream.go b/cloud/pkg/edgecontroller/controller/upstream.go index 7226d2922..0f982ab6d 100644 --- a/cloud/pkg/edgecontroller/controller/upstream.go +++ b/cloud/pkg/edgecontroller/controller/upstream.go @@ -247,9 +247,12 @@ func (uc *UpstreamController) dispatchMessage() { case model.ResourceTypePodPatch: uc.patchPodChan <- msg case model.ResourceTypePod: - if msg.GetOperation() == model.DeleteOperation { + switch msg.GetOperation() { + case model.DeleteOperation: uc.podDeleteChan <- msg - } else { + case model.InsertOperation: + uc.createPodChan <- msg + default: klog.Errorf("message: %s, operation type: %s unsupported", msg.GetID(), msg.GetOperation()) } case model.ResourceTypeRuleStatus: @@ -261,9 +264,6 @@ func (uc *UpstreamController) dispatchMessage() { case model.QueryOperation: uc.queryLeaseChan <- msg } - case model.ResourceTypeCreatePod: - uc.createPodChan <- msg - default: klog.Errorf("message: %s, resource type: %s unsupported", msg.GetID(), resourceType) } |