提交 335637f4 编写于 作者: P Priya Wadhwa

Name tarball by k8s version name

上级 b8bc4611
......@@ -29,7 +29,7 @@ import (
// CachePreloadedTarball caches the preloaded images tarball on the host machine
func CachePreloadedTarball(k8sVersion string) error {
targetDir := localpath.MakeMiniPath("cache", "preloaded-tarball")
targetFilepath := path.Join(targetDir, fmt.Sprintf("%s-k8s-%s.tar", Version, k8sVersion))
targetFilepath := path.Join(targetDir, fmt.Sprintf("%s.tar", k8sVersion))
if _, err := os.Stat(targetFilepath); err == nil {
glog.Infof("Found %s in cache, skipping downloading", targetFilepath)
......
......@@ -88,7 +88,7 @@ func (d *Driver) Create() error {
ContainerPort: constants.DockerDaemonPort,
},
)
volumeName, err := oci.CreatePreloadedImagesVolume(Version, d.NodeConfig.KubernetesVersion)
volumeName, err := oci.CreatePreloadedImagesVolume(d.NodeConfig.KubernetesVersion)
if err != nil {
glog.Infof("Unable to create preloaded images volume: %v", err)
}
......
......@@ -22,11 +22,11 @@ import (
"fmt"
"os/exec"
"path"
"path/filepath"
"strings"
"github.com/golang/glog"
"github.com/pkg/errors"
"k8s.io/minikube/pkg/minikube/localpath"
)
// DeleteAllVolumesByLabel deletes all volumes that have a specific label
......@@ -90,19 +90,20 @@ func allVolumesByLabel(ociBin string, label string) ([]string, error) {
return vols, err
}
func CreatePreloadedImagesVolume(kicVersion, k8sVersion string) (string, error) {
// CreatePreloadedImagesVolume creates a volume with preloaded images
func CreatePreloadedImagesVolume(k8sVersion string) (string, error) {
if err := PointToHostDockerDaemon(); err != nil {
return "", errors.Wrap(err, "point host docker-daemon")
}
volumeName := fmt.Sprintf("%s-k8s-%s", kicVersion, k8sVersion)
volumeName := fmt.Sprintf("k8s-%s", k8sVersion)
if dockerVolumeExists(volumeName) {
return volumeName, nil
}
if err := createDockerVolume(volumeName); err != nil {
return "", errors.Wrap(err, "creating docker volume")
}
targetDir := localpath.MakeMiniPath("cache", "preloaded-tarball")
tarballPath := path.Join(targetDir, fmt.Sprintf("%s-k8s-%s.tar", kicVersion, k8sVersion))
targetDir := filepath.Join("cache", "preloaded-tarball")
tarballPath := path.Join(targetDir, fmt.Sprintf("%s.tar", k8sVersion))
if err := extractTarballToVolume(tarballPath, volumeName); err != nil {
return "", errors.Wrap(err, "extracting tarball to volume")
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册