Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
Chu Peng 楚鹏
minikube
提交
9d0c80dc
M
minikube
项目概览
Chu Peng 楚鹏
/
minikube
与 Fork 源项目一致
从无法访问的项目Fork
通知
2
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
M
minikube
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
提交
9d0c80dc
编写于
9月 27, 2017
作者:
M
Matt Rickard
提交者:
GitHub
9月 27, 2017
浏览文件
操作
浏览文件
下载
差异文件
Merge pull request #2010 from adolphlwq/remove-repeated-pkg
remove repeated pkg and cmdUtil -> cmdutil
上级
a90b6a44
6d64d90d
变更
1
隐藏空白更改
内联
并排
Showing
1 changed file
with
16 addition
and
17 deletion
+16
-17
cmd/minikube/cmd/start.go
cmd/minikube/cmd/start.go
+16
-17
未找到文件。
cmd/minikube/cmd/start.go
浏览文件 @
9d0c80dc
...
...
@@ -33,14 +33,13 @@ import (
"github.com/spf13/cobra"
"github.com/spf13/viper"
cmdcfg
"k8s.io/minikube/cmd/minikube/cmd/config"
cmd
U
til
"k8s.io/minikube/cmd/util"
cmd
u
til
"k8s.io/minikube/cmd/util"
"k8s.io/minikube/pkg/minikube/bootstrapper"
"k8s.io/minikube/pkg/minikube/cluster"
cfg
"k8s.io/minikube/pkg/minikube/config"
"k8s.io/minikube/pkg/minikube/constants"
"k8s.io/minikube/pkg/minikube/kubernetes_versions"
"k8s.io/minikube/pkg/minikube/machine"
"k8s.io/minikube/pkg/util"
pkgutil
"k8s.io/minikube/pkg/util"
"k8s.io/minikube/pkg/util/kubeconfig"
"k8s.io/minikube/pkg/version"
...
...
@@ -74,7 +73,7 @@ var (
dockerEnv
[]
string
dockerOpt
[]
string
insecureRegistry
[]
string
extraOptions
util
.
ExtraOptionSlice
extraOptions
pkg
util
.
ExtraOptionSlice
)
// startCmd represents the start command
...
...
@@ -107,7 +106,7 @@ func runStart(cmd *cobra.Command, args []string) {
}
diskSize
:=
viper
.
GetString
(
humanReadableDiskSize
)
diskSizeMB
:=
util
.
CalculateDiskSizeInMB
(
diskSize
)
diskSizeMB
:=
pkg
util
.
CalculateDiskSizeInMB
(
diskSize
)
if
diskSizeMB
<
constants
.
MinimumDiskSizeMB
{
err
:=
fmt
.
Errorf
(
"Disk Size %dMB (%s) is too small, the minimum disk size is %dMB"
,
diskSizeMB
,
diskSize
,
constants
.
MinimumDiskSizeMB
)
...
...
@@ -148,17 +147,17 @@ func runStart(cmd *cobra.Command, args []string) {
}
return
err
}
err
=
util
.
RetryAfter
(
5
,
start
,
2
*
time
.
Second
)
err
=
pkg
util
.
RetryAfter
(
5
,
start
,
2
*
time
.
Second
)
if
err
!=
nil
{
glog
.
Errorln
(
"Error starting host: "
,
err
)
cmd
U
til
.
MaybeReportErrorAndExit
(
err
)
cmd
u
til
.
MaybeReportErrorAndExit
(
err
)
}
fmt
.
Println
(
"Getting VM IP address..."
)
ip
,
err
:=
host
.
Driver
.
GetIP
()
if
err
!=
nil
{
glog
.
Errorln
(
"Error getting VM IP address: "
,
err
)
cmd
U
til
.
MaybeReportErrorAndExit
(
err
)
cmd
u
til
.
MaybeReportErrorAndExit
(
err
)
}
selectedKubernetesVersion
:=
viper
.
GetString
(
kubernetesVersion
)
...
...
@@ -217,13 +216,13 @@ func runStart(cmd *cobra.Command, args []string) {
fmt
.
Println
(
"Moving files into cluster..."
)
if
err
:=
k8sBootstrapper
.
UpdateCluster
(
kubernetesConfig
);
err
!=
nil
{
glog
.
Errorln
(
"Error updating cluster: "
,
err
)
cmd
U
til
.
MaybeReportErrorAndExit
(
err
)
cmd
u
til
.
MaybeReportErrorAndExit
(
err
)
}
fmt
.
Println
(
"Setting up certs..."
)
if
err
:=
k8sBootstrapper
.
SetupCerts
(
kubernetesConfig
);
err
!=
nil
{
glog
.
Errorln
(
"Error configuring authentication: "
,
err
)
cmd
U
til
.
MaybeReportErrorAndExit
(
err
)
cmd
u
til
.
MaybeReportErrorAndExit
(
err
)
}
fmt
.
Println
(
"Connecting to cluster..."
)
...
...
@@ -237,7 +236,7 @@ func runStart(cmd *cobra.Command, args []string) {
fmt
.
Println
(
"Setting up kubeconfig..."
)
// setup kubeconfig
kubeConfigFile
:=
cmd
U
til
.
GetKubeConfigPath
()
kubeConfigFile
:=
cmd
u
til
.
GetKubeConfigPath
()
kubeCfgSetup
:=
&
kubeconfig
.
KubeConfigSetup
{
ClusterName
:
cfg
.
GetMachineName
(),
...
...
@@ -251,7 +250,7 @@ func runStart(cmd *cobra.Command, args []string) {
if
err
:=
kubeconfig
.
SetupKubeConfig
(
kubeCfgSetup
);
err
!=
nil
{
glog
.
Errorln
(
"Error setting up kubeconfig: "
,
err
)
cmd
U
til
.
MaybeReportErrorAndExit
(
err
)
cmd
u
til
.
MaybeReportErrorAndExit
(
err
)
}
fmt
.
Println
(
"Starting cluster components..."
)
...
...
@@ -259,12 +258,12 @@ func runStart(cmd *cobra.Command, args []string) {
if
!
exists
{
if
err
:=
k8sBootstrapper
.
StartCluster
(
kubernetesConfig
);
err
!=
nil
{
glog
.
Errorln
(
"Error starting cluster: "
,
err
)
cmd
U
til
.
MaybeReportErrorAndExit
(
err
)
cmd
u
til
.
MaybeReportErrorAndExit
(
err
)
}
}
else
{
if
err
:=
k8sBootstrapper
.
RestartCluster
(
kubernetesConfig
);
err
!=
nil
{
glog
.
Errorln
(
"Error restarting cluster: "
,
err
)
cmd
U
til
.
MaybeReportErrorAndExit
(
err
)
cmd
u
til
.
MaybeReportErrorAndExit
(
err
)
}
}
...
...
@@ -286,12 +285,12 @@ func runStart(cmd *cobra.Command, args []string) {
err
=
mountCmd
.
Start
()
if
err
!=
nil
{
glog
.
Errorf
(
"Error running command minikube mount %s"
,
err
)
cmd
U
til
.
MaybeReportErrorAndExit
(
err
)
cmd
u
til
.
MaybeReportErrorAndExit
(
err
)
}
err
=
ioutil
.
WriteFile
(
filepath
.
Join
(
constants
.
GetMinipath
(),
constants
.
MountProcessFileName
),
[]
byte
(
strconv
.
Itoa
(
mountCmd
.
Process
.
Pid
)),
0644
)
if
err
!=
nil
{
glog
.
Errorf
(
"Error writing mount process pid to file: %s"
,
err
)
cmd
U
til
.
MaybeReportErrorAndExit
(
err
)
cmd
u
til
.
MaybeReportErrorAndExit
(
err
)
}
}
...
...
@@ -322,10 +321,10 @@ You will need to move the files to the appropriate location and then set the cor
This can also be done automatically by setting the env var CHANGE_MINIKUBE_NONE_USER=true`
)
}
if
err
:=
util
.
MaybeChownDirRecursiveToMinikubeUser
(
constants
.
GetMinipath
());
err
!=
nil
{
if
err
:=
pkg
util
.
MaybeChownDirRecursiveToMinikubeUser
(
constants
.
GetMinipath
());
err
!=
nil
{
glog
.
Errorf
(
"Error recursively changing ownership of directory %s: %s"
,
constants
.
GetMinipath
(),
err
)
cmd
U
til
.
MaybeReportErrorAndExit
(
err
)
cmd
u
til
.
MaybeReportErrorAndExit
(
err
)
}
}
}
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录