From e44d9df0f4ede211a659a5bba3bad82f31e031d0 Mon Sep 17 00:00:00 2001 From: Victor Marmol Date: Fri, 1 May 2015 16:13:22 -0700 Subject: [PATCH] Changes to rkt's PortForward to match Runtime API. --- pkg/kubelet/rkt/runner.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/kubelet/rkt/runner.go b/pkg/kubelet/rkt/runner.go index 0d1ab694e60..447a31c79de 100644 --- a/pkg/kubelet/rkt/runner.go +++ b/pkg/kubelet/rkt/runner.go @@ -107,7 +107,7 @@ func (r *Runtime) ExecInContainer(containerID string, cmd []string, stdin io.Rea // findRktID returns the rkt uuid for the pod. // TODO(yifan): This is unefficient which require us to list // all the unit files. -func (r *Runtime) findRktID(pod kubecontainer.Pod) (string, error) { +func (r *Runtime) findRktID(pod *kubecontainer.Pod) (string, error) { units, err := r.systemd.ListUnits() if err != nil { return "", err @@ -150,7 +150,7 @@ func (r *Runtime) findRktID(pod kubecontainer.Pod) (string, error) { // - should we support nsenter + socat in a container, running with elevated privs and --pid=host? // // TODO(yifan): Merge with the same function in dockertools. -func (r *Runtime) PortForward(pod kubecontainer.Pod, port uint16, stream io.ReadWriteCloser) error { +func (r *Runtime) PortForward(pod *kubecontainer.Pod, port uint16, stream io.ReadWriteCloser) error { glog.V(4).Infof("Rkt port forwarding in container.") podInfos, err := r.getPodInfos()