我目前正在学习kubelet
,cri是用来调用不同的容器运行时uniformly
的,我想以rkt为例来了解如何通过远程调用docker以外的运行时
kubelet 和 cri shim 服务器之间通过gRPC
.
以创建 Pod 为例,kubeletcri shim client
最终会调用如下函数
// staging/scr/k8s.io/cri-api/pkg/apis/runtime/v1/api.pb.go line 8571
func (c *runtimeServiceClient) StopContainer(ctx context.Context, in *StopContainerRequest, opts ...grpc.CallOption) (*StopContainerResponse, error) {
out := new(StopContainerResponse)
err := c.cc.Invoke(ctx, "/runtime.v1.RuntimeService/CreateContainer", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
但是我在rkt的grpc中没有找到对应的rpc响应方式
是因为我在寻找错误的位置还是其他原因?
我真的很感激这方面的任何帮助。