kubernetes/pkg/client/tests/portfoward_test.go

type fakePortForwarder …

var _ …

func (pf *fakePortForwarder) PortForward(_ context.Context, name string, uid types.UID, port int32, stream io.ReadWriteCloser) error { … }

// fakePortForwardServer creates an HTTP server that can handle port forwarding
// requests.
func fakePortForwardServer(t *testing.T, testName string, serverSends, expectedFromClient map[int32]string) http.HandlerFunc { … }

func TestForwardPorts(t *testing.T) { … }

func TestForwardPortsReturnsErrorWhenAllBindsFailed(t *testing.T) { … }