diff --git a/cmd/genkubedocs/gen_kube_docs.go b/cmd/genkubedocs/gen_kube_docs.go index 97a7b4b353a..afef74e1a08 100644 --- a/cmd/genkubedocs/gen_kube_docs.go +++ b/cmd/genkubedocs/gen_kube_docs.go @@ -25,7 +25,7 @@ import ( apiservapp "k8s.io/kubernetes/cmd/kube-apiserver/app" cmapp "k8s.io/kubernetes/cmd/kube-controller-manager/app" proxyapp "k8s.io/kubernetes/cmd/kube-proxy/app" - klapp "k8s.io/kubernetes/cmd/kubelet/app" + kubeletapp "k8s.io/kubernetes/cmd/kubelet/app" schapp "k8s.io/kubernetes/plugin/cmd/kube-scheduler/app" ) @@ -66,7 +66,7 @@ func main() { cobra.GenMarkdownTree(scheduler, outDir) case "kubelet": // generate docs for kubelet - kubelet := klapp.NewKubeletCommand() + kubelet := kubeletapp.NewKubeletCommand() cobra.GenMarkdownTree(kubelet, outDir) default: fmt.Fprintf(os.Stderr, "Module %s is not supported", module) diff --git a/cmd/hyperkube/kubelet.go b/cmd/hyperkube/kubelet.go index e12b20db555..f6e9942bbc4 100644 --- a/cmd/hyperkube/kubelet.go +++ b/cmd/hyperkube/kubelet.go @@ -17,13 +17,13 @@ limitations under the License. package main import ( - kubelet "k8s.io/kubernetes/cmd/kubelet/app" + kubeletapp "k8s.io/kubernetes/cmd/kubelet/app" ) // NewKubelet creates a new hyperkube Server object that includes the // description and flags. func NewKubelet() *Server { - s := kubelet.NewKubeletServer() + s := kubeletapp.NewKubeletServer() hks := Server{ SimpleUsage: "kubelet", Long: `The kubelet binary is responsible for maintaining a set of containers on a diff --git a/cmd/kubelet/kubelet.go b/cmd/kubelet/kubelet.go index 2160efc9a32..0a472f4f205 100644 --- a/cmd/kubelet/kubelet.go +++ b/cmd/kubelet/kubelet.go @@ -25,7 +25,7 @@ import ( "os" "runtime" - "k8s.io/kubernetes/cmd/kubelet/app" + kubeletapp "k8s.io/kubernetes/cmd/kubelet/app" "k8s.io/kubernetes/pkg/util" "k8s.io/kubernetes/pkg/version/verflag" @@ -34,7 +34,7 @@ import ( func main() { runtime.GOMAXPROCS(runtime.NumCPU()) - s := app.NewKubeletServer() + s := kubeletapp.NewKubeletServer() s.AddFlags(pflag.CommandLine) util.InitFlags() diff --git a/contrib/mesos/pkg/executor/service/service.go b/contrib/mesos/pkg/executor/service/service.go index 7fca7c07104..1d3f858dd56 100644 --- a/contrib/mesos/pkg/executor/service/service.go +++ b/contrib/mesos/pkg/executor/service/service.go @@ -27,7 +27,7 @@ import ( log "github.com/golang/glog" bindings "github.com/mesos/mesos-go/executor" "github.com/spf13/pflag" - "k8s.io/kubernetes/cmd/kubelet/app" + kubeletapp "k8s.io/kubernetes/cmd/kubelet/app" "k8s.io/kubernetes/contrib/mesos/pkg/executor" "k8s.io/kubernetes/contrib/mesos/pkg/executor/config" "k8s.io/kubernetes/contrib/mesos/pkg/hyperkube" @@ -43,7 +43,7 @@ import ( ) type KubeletExecutorServer struct { - *app.KubeletServer + *kubeletapp.KubeletServer SuicideTimeout time.Duration LaunchGracePeriod time.Duration @@ -53,7 +53,7 @@ type KubeletExecutorServer struct { func NewKubeletExecutorServer() *KubeletExecutorServer { k := &KubeletExecutorServer{ - KubeletServer: app.NewKubeletServer(), + KubeletServer: kubeletapp.NewKubeletServer(), SuicideTimeout: config.DefaultSuicideTimeout, LaunchGracePeriod: config.DefaultLaunchGracePeriod, } @@ -151,8 +151,8 @@ func (s *KubeletExecutorServer) runKubelet( if err == nil { // apply Messo specific settings executorDone := make(chan struct{}) - kcfg.Builder = func(kc *app.KubeletConfig) (app.KubeletBootstrap, *kconfig.PodConfig, error) { - k, pc, err := app.CreateAndInitKubelet(kc) + kcfg.Builder = func(kc *kubeletapp.KubeletConfig) (kubeletapp.KubeletBootstrap, *kconfig.PodConfig, error) { + k, pc, err := kubeletapp.CreateAndInitKubelet(kc) if err != nil { return k, pc, err } diff --git a/contrib/mesos/pkg/node/statusupdater.go b/contrib/mesos/pkg/node/statusupdater.go index c9d8172473c..a69eea05a1d 100644 --- a/contrib/mesos/pkg/node/statusupdater.go +++ b/contrib/mesos/pkg/node/statusupdater.go @@ -21,7 +21,7 @@ import ( "time" log "github.com/golang/glog" - kubelet "k8s.io/kubernetes/cmd/kubelet/app" + kubeletapp "k8s.io/kubernetes/cmd/kubelet/app" "k8s.io/kubernetes/contrib/mesos/pkg/runtime" "k8s.io/kubernetes/pkg/api" "k8s.io/kubernetes/pkg/api/errors" @@ -46,7 +46,7 @@ type StatusUpdater struct { } func NewStatusUpdater(client *client.Client, relistPeriod time.Duration, nowFunc func() time.Time) *StatusUpdater { - kubecfg := kubelet.NewKubeletServer() // only create to get the config, this is without side-effects + kubecfg := kubeletapp.NewKubeletServer() // only create to get the config, this is without side-effects return &StatusUpdater{ client: client, relistPeriod: relistPeriod, diff --git a/contrib/mesos/pkg/node/statusupdater_test.go b/contrib/mesos/pkg/node/statusupdater_test.go index ea3b831802e..952b6bb263e 100644 --- a/contrib/mesos/pkg/node/statusupdater_test.go +++ b/contrib/mesos/pkg/node/statusupdater_test.go @@ -22,7 +22,7 @@ import ( "github.com/stretchr/testify/assert" "k8s.io/kubernetes/cmd/kube-controller-manager/app" - kubelet "k8s.io/kubernetes/cmd/kubelet/app" + kubeletapp "k8s.io/kubernetes/cmd/kubelet/app" "k8s.io/kubernetes/pkg/api" "k8s.io/kubernetes/pkg/api/unversioned" ) @@ -47,7 +47,7 @@ func Test_nodeWithUpdatedStatus(t *testing.T) { } cm := app.NewCMServer() - kubecfg := kubelet.NewKubeletServer() + kubecfg := kubeletapp.NewKubeletServer() assert.True(t, kubecfg.NodeStatusUpdateFrequency*3 < cm.NodeMonitorGracePeriod) // sanity check for defaults n := testNode(0, api.ConditionTrue, "KubeletReady")