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"}
	}
}
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"}
	}
}
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 ( " " ) ( ) response := make ( chan error , 1 ) go func ( ) { response <- dg . loadImage ( ctx , inputStream ) } ( ) select { case resp := <- response : return resp case <- ctx . Done ( ) : return & DockerTimeoutError { timeout , " " } } }
// LoadImage invokes loads an image from an input stream, with a specified timeout
LoadImage invokes loads an image from an input stream with a specified timeout