Function newDockerClientFromMinikube

pkg/devspace/docker/client.go:114–159

(ctx context.Context, kubectlClient kubectl.Client)

}

func newDockerClientFromMinikube(ctx context.Context, kubectlClient kubectl.Client) (Client, error) {
	if !kubectl.IsMinikubeKubernetes(kubectlClient) {
		return nil, errNotMinikube
	}
	
	env, err := GetMinikubeEnvironment(ctx, kubectlClient.CurrentContext())
	if err != nil {
		return nil, errors.Errorf("can't retrieve minikube docker environment due to error: %v", err)
	}
	
	var httpclient *http.Client
	if dockerCertPath := env["DOCKER_CERT_PATH"]; dockerCertPath != "" {
		options := tlsconfig.Options{
			CAFile:             filepath.Join(dockerCertPath, "ca.pem"),
			CertFile:           filepath.Join(dockerCertPath, "cert.pem"),
			KeyFile:            filepath.Join(dockerCertPath, "key.pem"),
			InsecureSkipVerify: env["DOCKER_TLS_VERIFY"] == "",
		}
		tlsc, err := tlsconfig.Client(options)
		if err != nil {
			return nil, err
		}
		
		httpclient = &http.Client{
			Transport: &http.Transport{
				TLSClientConfig: tlsc,
			},
			CheckRedirect: dockerclient.CheckRedirect,
		}
	}
	
	host := env["DOCKER_HOST"]
	if host == "" {
		host = dockerclient.DefaultDockerHost
	}
	
	cli, err := dockerclient.NewClientWithOpts(dockerclient.WithHost(host), dockerclient.WithVersion(env["DOCKER_API_VERSION"]), dockerclient.WithHTTPClient(httpclient), dockerclient.WithHTTPHeaders(nil))
	if err != nil {
		return nil, err
	}
	
	return &client{
		APIClient:   cli,
		minikubeEnv: env,
	}, nil
}

func GetMinikubeEnvironment(ctx context.Context, kubeContext string) (map[string]string, error) {
	out, err := command.Output(ctx, "", expand.ListEnviron(os.Environ()...), "minikube", "docker-env", "--shell", "none", "--profile", kubeContext)