code: func (dg *dockerGoClient) LoadImage(ctx context.Context, inputStream io.Reader, timeout time.Duration) error {
  	ctx, cancel := context.WithTimeout(ctx, timeout)
  	defer cancel()
  	defer metrics.MetricsEngineGlobal.RecordDockerMetric("LOAD_IMAGE")()
  	response := make(chan error, 1)
  	go func() {
  		response <- dg.loadImage(ctx, inputStream)
  	}()
  	select {
  	case resp := <-response:
  		return resp
  	case <-ctx.Done():
  		return &DockerTimeoutError{timeout, "loading image"}
  	}
  }
docs: // LoadImage invokes loads an image from an input stream, with a specified timeout