github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-05 18:24:07 +00:00
Code Issues Projects Releases Wiki Activity

Changes to rkt's PortForward to match Runtime API.

Browse Source
This commit is contained in:
Victor Marmol 2015-05-01 16:13:22 -07:00
parent 79fc8bee34
commit e44d9df0f4
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/kubelet/rkt/runner.go
View File

@ -107,7 +107,7 @@ func (r *Runtime) ExecInContainer(containerID string, cmd []string, stdin io.Rea
// findRktID returns the rkt uuid for the pod. // findRktID returns the rkt uuid for the pod.
// TODO(yifan): This is unefficient which require us to list // TODO(yifan): This is unefficient which require us to list
// all the unit files. // 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() units, err := r.systemd.ListUnits()
if err != nil { if err != nil {
return "", err 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? // - should we support nsenter + socat in a container, running with elevated privs and --pid=host?
// //
// TODO(yifan): Merge with the same function in dockertools. // 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.") glog.V(4).Infof("Rkt port forwarding in container.")
podInfos, err := r.getPodInfos() podInfos, err := r.getPodInfos()