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

Commit c48afd3

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

File tree

1 file changed

+14
-3
lines changed

1 file changed

+14
-3
lines changed

pkg/kubelet/hyper/hyperclient.go

Lines changed: 14 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -505,9 +505,20 @@ func (client *HyperClient) RemovePod(podID string) error {
505505
}
506506

507507
func (client *HyperClient) StartPod(podID string) error {
508-
v := url.Values{}
509-
v.Set(KEY_POD_ID, podID)
510-
_, _, err := client.call("POST", "/pod/start?"+v.Encode(), "", nil)
508+
stream, err := client.client.PodStart(context.Background())
509+
if err != nil {
510+
return err
511+
}
512+
513+
request := grpctypes.PodStartMessage{
514+
PodID: podID,
515+
}
516+
err = stream.Send(&request)
517+
if err != nil {
518+
return err
519+
}
520+
521+
_, err = stream.Recv()
511522
if err != nil {
512523
return err
513524
}

0 commit comments

Comments
 (0)