Manual changes for go-containerregistry update.

pkg/minikube/machine/cache_images.go

@@ -18,20 +18,19 @@ package machine
 
 import (
 	"io/ioutil"
-	"net/http"
 	"os"
 	"os/exec"
 	"path"
 	"path/filepath"
 	"runtime"
 	"strings"
 
-	"github.com/google/go-containerregistry/v1/tarball"
+	"github.com/google/go-containerregistry/pkg/v1/tarball"
 
-	"github.com/google/go-containerregistry/authn"
+	"github.com/google/go-containerregistry/pkg/authn"
 
-	"github.com/google/go-containerregistry/name"
-	"github.com/google/go-containerregistry/v1/remote"
+	"github.com/google/go-containerregistry/pkg/name"
+	"github.com/google/go-containerregistry/pkg/v1/remote"
 
 	"golang.org/x/sync/errgroup"
 
@@ -296,14 +295,16 @@ func CacheImage(image, dst string) error {
 		return errors.Wrap(err, "creating docker image name")
 	}
 
-	auth, err := authn.DefaultKeychain.Resolve(tag.Registry)
-	if err != nil {
-		return errors.Wrap(err, "setting up registry auth")
-	}
-	img, err := remote.Image(tag, auth, http.DefaultTransport)
+	img, err := remote.Image(tag, remote.WithAuthFromKeychain(authn.DefaultKeychain))
 	if err != nil {
 		return errors.Wrap(err, "fetching remote image")
 	}
 
-	return tarball.Write(dstPath, tag, img, nil)
+	glog.Infoln("OPENING: ", dstPath)
+	f, err := os.Create(dstPath)
+	if err != nil {
+		return err
+	}
+	defer f.Close()
+	return tarball.Write(tag, img, nil, f)
 }

test/integration/persistence_test.go

@@ -20,6 +20,7 @@ package integration
 
 import (
 	"path/filepath"
+	"strings"
 	"testing"
 	"time"
 
@@ -28,10 +29,10 @@ import (
 )
 
 func TestPersistence(t *testing.T) {
+	minikubeRunner := NewMinikubeRunner(t)
 	if strings.Contains(minikubeRunner.StartArgs, "--vm-driver=none") {
 		t.Skip("skipping test as none driver does not support persistence")
 	}
-	minikubeRunner := NewMinikubeRunner(t)
 	minikubeRunner.EnsureRunning()
 
 	kubectlRunner := util.NewKubectlRunner(t)