code: func NewRemoteRuntimeService(endpoint string, connectionTimeout time.Duration) (internalapi.RuntimeService, error) {
  	klog.V(3).Infof("Connecting to runtime service %s", endpoint)
  	addr, dailer, err := util.GetAddressAndDialer(endpoint)
  	if err != nil {
  		return nil, err
  	}
  	ctx, cancel := context.WithTimeout(context.Background(), connectionTimeout)
  	defer cancel()
  
  	conn, err := grpc.DialContext(ctx, addr, grpc.WithInsecure(), grpc.WithDialer(dailer), grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(maxMsgSize)))
  	if err != nil {
  		klog.Errorf("Connect remote runtime %s failed: %v", addr, err)
  		return nil, err
  	}
  
  	return &RemoteRuntimeService{
  		timeout:       connectionTimeout,
  		runtimeClient: runtimeapi.NewRuntimeServiceClient(conn),
  		logReduction:  logreduction.NewLogReduction(identicalErrorDelay),
  	}, nil
  }
docs: // NewRemoteRuntimeService creates a new internalapi.RuntimeService.