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 /edge/pkg | |
| 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 'edge/pkg')
| -rw-r--r-- | edge/pkg/metamanager/client/pod.go | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/edge/pkg/metamanager/client/pod.go b/edge/pkg/metamanager/client/pod.go index c78cea878..ce0c851b9 100644 --- a/edge/pkg/metamanager/client/pod.go +++ b/edge/pkg/metamanager/client/pod.go @@ -52,7 +52,7 @@ func newPods(namespace string, s SendInterface) *pods { } func (c *pods) Create(cm *corev1.Pod) (*corev1.Pod, error) { - resource := fmt.Sprintf("%s/%s/%s", c.namespace, model.ResourceTypeCreatePod, cm.Name) + resource := fmt.Sprintf("%s/%s/%s", c.namespace, model.ResourceTypePod, cm.Name) podMsg := message.BuildMsg(modules.MetaGroup, "", modules.EdgedModuleName, resource, model.InsertOperation, *cm) resp, err := c.send.SendSync(podMsg) if err != nil { @@ -161,11 +161,8 @@ func handlePodResp(resource string, content []byte) (*corev1.Pod, error) { } if reflect.DeepEqual(podResp.Err, apierrors.StatusError{}) { - resourceArray := strings.Split(resource, constants.ResourceSep) - if !(len(resourceArray) >= 2 && resourceArray[1] == model.ResourceTypeCreatePod) { - if err = updatePodDB(resource, podResp.Object); err != nil { - return nil, fmt.Errorf("update pod meta failed, err: %v", err) - } + if err = updatePodDB(resource, podResp.Object); err != nil { + return nil, fmt.Errorf("update pod meta failed, err: %v", err) } return podResp.Object, nil } |