Use docker client lib instead of binary for pulls

cmd/kubelet/kubelet.go

@@ -47,8 +47,6 @@ var (
 	dockerEndpoint     = flag.String("docker_endpoint", "", "If non-empty, use this for the docker endpoint to communicate with")
 )
 
-const dockerBinary = "/usr/bin/docker"
-
 func main() {
 	flag.Parse()
 	util.InitLogs()

pkg/kubelet/fake_docker_client.go

@@ -17,6 +17,8 @@ limitations under the License.
 package kubelet
 
 import (
+	"fmt"
+
 	"github.com/fsouza/go-dockerclient"
 )
 
@@ -27,6 +29,7 @@ type FakeDockerClient struct {
 	err           error
 	called        []string
 	stopped       []string
+	pulled        []string
 	Created       []string
 }
 
@@ -68,6 +71,12 @@ func (f *FakeDockerClient) StopContainer(id string, timeout uint) error {
 	return f.err
 }
 
+func (f *FakeDockerClient) PullImage(opts docker.PullImageOptions, auth docker.AuthConfiguration) error {
+	f.appendCall("pull")
+	f.pulled = append(f.pulled, fmt.Sprintf("%s/%s:%s", opts.Repository, opts.Registry, opts.Tag))
+	return f.err
+}
+
 type FakeDockerPuller struct {
 	ImagesPulled []string
 

pkg/kubelet/kubelet.go

@@ -24,7 +24,6 @@ import (
 	"net"
 	"net/http"
 	"os"
-	"os/exec"
 	"path"
 	"path/filepath"
 	"sort"
@@ -59,6 +58,7 @@ type DockerInterface interface {
 	CreateContainer(docker.CreateContainerOptions) (*docker.Container, error)
 	StartContainer(id string, hostConfig *docker.HostConfig) error
 	StopContainer(id string, timeout uint) error
+	PullImage(opts docker.PullImageOptions, auth docker.AuthConfiguration) error
 }
 
 // Type to make it clear when we're working with docker container Ids
@@ -107,7 +107,7 @@ const (
 // they are not watched. Never returns.
 func (kl *Kubelet) RunKubelet(dockerEndpoint, config_path, manifest_url, etcd_servers, address string, port uint) {
 	if kl.DockerPuller == nil {
-		kl.DockerPuller = MakeDockerPuller(dockerEndpoint)
+		kl.DockerPuller = kl.MakeDockerPuller()
 	}
 	updateChannel := make(chan manifestUpdate)
 	if config_path != "" {
@@ -209,28 +209,23 @@ func (kl *Kubelet) getContainerId(manifest *api.ContainerManifest, container *ap
 	return "", nil
 }
 
-type dockerPuller struct {
-	endpoint string
+func (kl *Kubelet) MakeDockerPuller() DockerPuller {
+	return dockerPuller{
+		client: kl.DockerClient,
+	}
 }
 
-func MakeDockerPuller(endpoint string) DockerPuller {
-	return dockerPuller{
-		endpoint: endpoint,
-	}
+type dockerPuller struct {
+	client DockerInterface
 }
 
 func (p dockerPuller) Pull(image string) error {
-	var cmd *exec.Cmd
-	if len(p.endpoint) == 0 {
-		cmd = exec.Command("docker", "pull", image)
-	} else {
-		cmd = exec.Command("docker", "-H", p.endpoint, "pull", image)
+	image, tag := parseImageName(image)
+	opts := docker.PullImageOptions{
+		Repository: image,
+		Tag:        tag,
 	}
-	err := cmd.Start()
-	if err != nil {
-		return err
-	}
-	return cmd.Wait()
+	return p.client.PullImage(opts, docker.AuthConfiguration{})
 }
 
 // Converts "-" to "_-_" and "_" to "___" so that we can use "--" to meaningfully separate parts of a docker name.
@@ -335,6 +330,29 @@ func makePortsAndBindings(container *api.Container) (map[docker.Port]struct{}, m
 	return exposedPorts, portBindings
 }
 
+// Parses image name including an tag and returns image name and tag
+// TODO: Future Docker versions can parse the tag on daemon side, see:
+// https://github.com/dotcloud/docker/issues/6876
+// So this can be deprecated at some point.
+func parseImageName(image string) (string, string) {
+	tag := ""
+	parts := strings.SplitN(image, "/", 2)
+	repo := ""
+	if len(parts) == 2 {
+		repo = parts[0]
+		image = parts[1]
+	}
+	parts = strings.SplitN(image, ":", 2)
+	if len(parts) == 2 {
+		image = parts[0]
+		tag = parts[1]
+	}
+	if repo != "" {
+		image = fmt.Sprintf("%s/%s", repo, image)
+	}
+	return image, tag
+}
+
 // Run a single container from a manifest. Returns the docker container ID
 func (kl *Kubelet) runContainer(manifest *api.ContainerManifest, container *api.Container, netMode string) (id DockerId, err error) {
 	envVariables := makeEnvironmentVariables(container)

pkg/kubelet/kubelet_test.go

@@ -978,3 +978,30 @@ func TestGetContainerStatsOnNonExistContainer(t *testing.T) {
 	}
 	mockCadvisor.AssertExpectations(t)
 }
+
+func TestParseImageName(t *testing.T) {
+	name, tag := parseImageName("ubuntu")
+	if name != "ubuntu" || tag != "" {
+		t.Fatal("Unexpected name/tag: %s/%s", name, tag)
+	}
+
+	name, tag = parseImageName("ubuntu:2342")
+	if name != "ubuntu" || tag != "2342" {
+		t.Fatal("Unexpected name/tag: %s/%s", name, tag)
+	}
+
+	name, tag = parseImageName("foo/bar:445566")
+	if name != "foo/bar" || tag != "445566" {
+		t.Fatal("Unexpected name/tag: %s/%s", name, tag)
+	}
+
+	name, tag = parseImageName("registry.example.com:5000/foobar")
+	if name != "registry.example.com:5000/foobar" || tag != "" {
+		t.Fatal("Unexpected name/tag: %s/%s", name, tag)
+	}
+
+	name, tag = parseImageName("registry.example.com:5000/foobar:5342")
+	if name != "registry.example.com:5000/foobar" || tag != "5342" {
+		t.Fatal("Unexpected name/tag: %s/%s", name, tag)
+	}
+}