kubernetes/test/e2e/kubectl/portforward.go

const podName …

const podCheckInterval …

const postStartWaitTimeout …

var portForwardRegexp …

func pfPod(expectedClientData, chunks, chunkSize, chunkIntervalMillis string, bindAddress string) *v1.Pod { … }

// WaitForTerminatedContainer waits till a given container be terminated for a given pod.
func WaitForTerminatedContainer(ctx context.Context, f *framework.Framework, pod *v1.Pod, containerName string) error { … }

type portForwardCommand …

// Stop attempts to gracefully stop `kubectl port-forward`, only killing it if necessary.
// This helps avoid spdy goroutine leaks in the Kubelet.
func (c *portForwardCommand) Stop() { … }

// runPortForward runs port-forward, warning, this may need root functionality on some systems.
func runPortForward(ns, podName string, port int) *portForwardCommand { … }

func doTestConnectSendDisconnect(ctx context.Context, bindAddress string, f *framework.Framework) { … }

func doTestMustConnectSendNothing(ctx context.Context, bindAddress string, f *framework.Framework) { … }

func doTestMustConnectSendDisconnect(ctx context.Context, bindAddress string, f *framework.Framework) { … }

func doTestOverWebSockets(ctx context.Context, bindAddress string, f *framework.Framework) { … }

var _ …

func wsRead(conn *websocket.Conn) (byte, []byte, error) { … }

func wsWrite(conn *websocket.Conn, channel byte, data []byte) error { … }