Function NewRuntimeService

integration/remote/remote_runtime.go:61–78

NewRuntimeService creates a legacy-style CRI runtime client backed by the upstream Kubernetes CRI client.

(endpoint string, connectionTimeout time.Duration)

// NewRuntimeService creates a legacy-style CRI runtime client backed by the
// upstream Kubernetes CRI client.
func NewRuntimeService(endpoint string, connectionTimeout time.Duration) (*RuntimeService, error) {
	runtimeService, err := upstreamcri.NewRemoteRuntimeService(context.Background(), endpoint, connectionTimeout, nil, false)
	if err != nil {
		return nil, err
	}

	runtimeConn, err := newRuntimeClientConn(endpoint)
	if err != nil {
		_ = runtimeService.Close(context.Background())
		return nil, err
	}

	return &RuntimeService{
		runtimeService: runtimeService,
		runtimeClient:  runtimeapi.NewRuntimeServiceClient(runtimeConn),
		runtimeConn:    runtimeConn,
	}, nil
}

func newRuntimeClientConn(endpoint string) (*grpc.ClientConn, error) {
	addr, dialer, err := criutil.GetAddressAndDialer(endpoint)