Skip to content
This repository was archived by the owner on Feb 8, 2021. It is now read-only.

Commit a311ca2

Browse files
committed
grpc for UpdatePodLabels
Signed-off-by: Yao Zengzeng <yaozengzeng@zju.edu.cn>
1 parent e6f81cb commit a311ca2

File tree

1 file changed

+5
-9
lines changed

1 file changed

+5
-9
lines changed

pkg/kubelet/hyper/hyperclient.go

Lines changed: 5 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -826,17 +826,13 @@ func (client *HyperClient) UpdateServices(podId string, services []HyperService)
826826
}
827827

828828
func (client *HyperClient) UpdatePodLabels(podId string, labels map[string]string) error {
829-
v := url.Values{}
830-
v.Set("podId", podId)
831-
v.Set("override", "true")
832-
833-
labelsData, err := json.Marshal(labels)
834-
if err != nil {
835-
return err
829+
request := grpctypes.PodLabelsRequest{
830+
PodID: podId,
831+
Override: true,
832+
Labels: labels,
836833
}
837-
v.Set("labels", string(labelsData))
838834

839-
_, _, err = client.call("POST", "/pod/labels?"+v.Encode(), "", nil)
835+
_, err := client.client.SetPodLabels(context.Background(), &request)
840836
if err != nil {
841837
return err
842838
}

0 commit comments

Comments
 (0)