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

Commit 2cdc2ca

Browse files
author
harry
authored
Merge pull request #129 from YaoZengzeng/grpc-start-pod
grpc for StartPod
2 parents f6f49db + c48afd3 commit 2cdc2ca

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
@@ -461,9 +461,20 @@ func (client *HyperClient) RemovePod(podID string) error {
461461
}
462462

463463
func (client *HyperClient) StartPod(podID string) error {
464-
v := url.Values{}
465-
v.Set(KEY_POD_ID, podID)
466-
_, _, err := client.call("POST", "/pod/start?"+v.Encode(), "", nil)
464+
stream, err := client.client.PodStart(context.Background())
465+
if err != nil {
466+
return err
467+
}
468+
469+
request := grpctypes.PodStartMessage{
470+
PodID: podID,
471+
}
472+
err = stream.Send(&request)
473+
if err != nil {
474+
return err
475+
}
476+
477+
_, err = stream.Recv()
467478
if err != nil {
468479
return err
469480
}

0 commit comments

Comments
 (0)