write pull image progress

.dockerignore

@@ -1 +1,3 @@
-!debug-agent
+*
+!debug-agent
+

.travis.yml

@@ -30,6 +30,6 @@ before_deploy:
 
 deploy:
   - provider: script
-    script: bash docker_push.sh
+    script: bash ./scripts/docker_push.sh
     on:
       tags: true

pkg/agent/runtime.go

@@ -49,7 +49,7 @@ func (a *DebugAttacher) AttachContainer(name string, uid kubetype.UID, container
 
 // GetAttacher returns an implementation of Attacher
 func (m *RuntimeManager) GetAttacher(image string, command []string) kubeletremote.Attacher {
-	return &DebugAttacher{runtime: m, image: image}
+	return &DebugAttacher{runtime: m, image: image, command: command}
 }
 
 // DebugContainer executes the main debug flow
@@ -59,7 +59,7 @@ func (m *RuntimeManager) DebugContainer(container, image string, command []strin
 
 	// step 1: pull image
 	stdout.Write([]byte(fmt.Sprintf("pulling image %s ...\n\r", image)))
-	err := m.PullImage(image)
+	err := m.PullImage(image, stdout)
 	if err != nil {
 		return err
 	}
@@ -128,16 +128,17 @@ func (m *RuntimeManager) CreateContainer(targetId string, image string, command
 	return &body, nil
 }
 
-func (m *RuntimeManager) PullImage(image string) error {
+func (m *RuntimeManager) PullImage(image string, stdout io.WriteCloser) error {
 	ctx, cancel := m.getTimeoutContext()
 	defer cancel()
-	resp, err := m.client.ImagePull(ctx, image, types.ImagePullOptions{})
+	out, err := m.client.ImagePull(ctx, image, types.ImagePullOptions{})
 	if err != nil {
 		return err
 	}
-	defer resp.Close()
+	defer out.Close()
+	// write pull progress to user
+	io.Copy(stdout, out)
 	return nil
-
 }
 
 func (m *RuntimeManager) CleanContainer(id string) {

pkg/agent/server.go

@@ -97,7 +97,6 @@ func (s *Server) ServeDebug(w http.ResponseWriter, req *http.Request) {
 		TTY:    true,
 	}
 
-	log.Printf("start serve attach, id: %s, image: %s, command: %v \n", containerId, image, commandSlice)
 	// replace Attacher implementation to hook the ServeAttach procedure
 	kubeletremote.ServeAttach(
 		w,

scripts/agent_daemonset.yml

@@ -0,0 +1,46 @@
+apiVersion: extensions/v1beta1
+kind: DaemonSet
+metadata:
+  labels:
+    app: debug-agent
+  name: debug-agent
+spec:
+  selector:
+    matchLabels:
+      app: debug-agent
+  template:
+    metadata:
+      labels:
+        app: debug-agent
+    spec:
+      containers:
+      - image: aylei/debug-agent:latest
+        imagePullPolicy: IfNotPresent
+        livenessProbe:
+          failureThreshold: 3
+          httpGet:
+            path: /healthz
+            port: 10027
+            scheme: HTTP
+          initialDelaySeconds: 10
+          periodSeconds: 10
+          successThreshold: 1
+          timeoutSeconds: 1
+        name: debug-agent
+        ports:
+        - containerPort: 10027
+          hostPort: 10027
+          name: http
+          protocol: TCP
+        volumeMounts:
+        - name: docker
+          mountPath: "/var/run/docker.sock"
+      hostNetwork: true
+      volumes:
+      - name: docker
+        hostPath:
+          path: /var/run/docker.sock
+  updateStrategy:
+    rollingUpdate:
+      maxUnavailable: 5
+    type: RollingUpdate