diff --git a/cmd/kubelet/app/server.go b/cmd/kubelet/app/server.go index f38d09204b..332476d7f1 100644 --- a/cmd/kubelet/app/server.go +++ b/cmd/kubelet/app/server.go @@ -126,7 +126,7 @@ func UnsecuredKubeletDeps(s *options.KubeletServer) (*kubelet.KubeletDeps, error var dockerClient dockertools.DockerInterface if s.ContainerRuntime == "docker" { - dockerClient = dockertools.ConnectToDockerOrDie(s.DockerEndpoint, s.RuntimeRequestTimeout.Duration) + dockerClient = dockertools.CreateDockerClientOrDie(s.DockerEndpoint, s.RuntimeRequestTimeout.Duration) } else { dockerClient = nil } diff --git a/contrib/mesos/pkg/executor/executor_test.go b/contrib/mesos/pkg/executor/executor_test.go index 6425068100..fe3845c205 100644 --- a/contrib/mesos/pkg/executor/executor_test.go +++ b/contrib/mesos/pkg/executor/executor_test.go @@ -184,7 +184,7 @@ func TestExecutorLaunchAndKillTask(t *testing.T) { mockDriver = &MockExecutorDriver{} registry = newFakeRegistry() executor = New(Config{ - Docker: dockertools.ConnectToDockerOrDie("fake://", 0), + Docker: dockertools.CreateDockerClientOrDie("fake://", 0), NodeInfos: make(chan NodeInfo, 1), Registry: registry, }) @@ -388,7 +388,7 @@ func TestExecutorFrameworkMessage(t *testing.T) { kubeletFinished = make(chan struct{}) registry = newFakeRegistry() executor = New(Config{ - Docker: dockertools.ConnectToDockerOrDie("fake://", 0), + Docker: dockertools.CreateDockerClientOrDie("fake://", 0), NodeInfos: make(chan NodeInfo, 1), ShutdownAlert: func() { close(kubeletFinished) @@ -585,7 +585,7 @@ func TestExecutorShutdown(t *testing.T) { kubeletFinished = make(chan struct{}) exitCalled = int32(0) executor = New(Config{ - Docker: dockertools.ConnectToDockerOrDie("fake://", 0), + Docker: dockertools.CreateDockerClientOrDie("fake://", 0), NodeInfos: make(chan NodeInfo, 1), ShutdownAlert: func() { close(kubeletFinished) diff --git a/contrib/mesos/pkg/executor/mock_test.go b/contrib/mesos/pkg/executor/mock_test.go index 7462d638dd..c17973b10a 100644 --- a/contrib/mesos/pkg/executor/mock_test.go +++ b/contrib/mesos/pkg/executor/mock_test.go @@ -75,7 +75,7 @@ func (m *MockExecutorDriver) SendFrameworkMessage(msg string) (mesosproto.Status func NewTestKubernetesExecutor() *Executor { return New(Config{ - Docker: dockertools.ConnectToDockerOrDie("fake://", 0), + Docker: dockertools.CreateDockerClientOrDie("fake://", 0), Registry: newFakeRegistry(), }) } diff --git a/contrib/mesos/pkg/executor/service/service.go b/contrib/mesos/pkg/executor/service/service.go index 90d184fc10..56aa7aa04e 100644 --- a/contrib/mesos/pkg/executor/service/service.go +++ b/contrib/mesos/pkg/executor/service/service.go @@ -108,7 +108,7 @@ func (s *KubeletExecutorServer) runExecutor( exec := executor.New(executor.Config{ Registry: registry, APIClient: apiclient, - Docker: dockertools.ConnectToDockerOrDie(s.DockerEndpoint, 0), + Docker: dockertools.CreateDockerClientOrDie(s.DockerEndpoint, 0), SuicideTimeout: s.SuicideTimeout, KubeletFinished: kubeletFinished, ExitFunc: os.Exit, diff --git a/pkg/kubelet/dockertools/docker.go b/pkg/kubelet/dockertools/docker.go index cfff0ac8c3..d08693a89c 100644 --- a/pkg/kubelet/dockertools/docker.go +++ b/pkg/kubelet/dockertools/docker.go @@ -362,13 +362,13 @@ func getDockerClient(dockerEndpoint string) (*dockerapi.Client, error) { return dockerapi.NewEnvClient() } -// ConnectToDockerOrDie creates docker client connecting to docker daemon. -// If the endpoint passed in is "fake://", a fake docker client -// will be returned. The program exits if error occurs. The requestTimeout -// is the timeout for docker requests. If timeout is exceeded, the request -// will be cancelled and throw out an error. If requestTimeout is 0, a default -// value will be applied. -func ConnectToDockerOrDie(dockerEndpoint string, requestTimeout time.Duration) DockerInterface { +// CreateDockerClientOrDie creates a docker client for connecting to the docker daemon. +// It does not actually try to connect to the docker daemon! +// requestTimeout is the timeout for docker requests. +// If requestTimeout=0, a default value is used instead. +// Pass dockerEndpoint="fake://" to create a fake docker client. +// Errors during client creation will cause program termination. +func CreateDockerClientOrDie(dockerEndpoint string, requestTimeout time.Duration) DockerInterface { if dockerEndpoint == "fake://" { return NewFakeDockerClient() } diff --git a/test/e2e_node/image.go b/test/e2e_node/image.go index 614b686b31..816caf6e38 100644 --- a/test/e2e_node/image.go +++ b/test/e2e_node/image.go @@ -40,7 +40,7 @@ func NewConformanceImage(containerRuntime string, image string) (ci ConformanceI //TODO: do not expose kubelet implementation details after we refactor the runtime API. func dockerRuntime() kubecontainer.Runtime { - dockerClient := dockertools.ConnectToDockerOrDie("", 0) + dockerClient := dockertools.CreateDockerClientOrDie("", 0) pm := kubepod.NewBasicPodManager(nil) dm := dockertools.NewDockerManager( dockerClient,