kubernetes/pkg/client/tests/remotecommand_test.go

type fakeExecutor …

func (ex *fakeExecutor) ExecInContainer(_ context.Context, name string, uid types.UID, container string, cmd []string, in io.Reader, out, err io.WriteCloser, tty bool, resize <-chan remoteclient.TerminalSize, timeout time.Duration) error { … }

func (ex *fakeExecutor) AttachContainer(_ context.Context, name string, uid types.UID, container string, in io.Reader, out, err io.WriteCloser, tty bool, resize <-chan remoteclient.TerminalSize) error { … }

func (ex *fakeExecutor) run(name string, uid types.UID, container string, cmd []string, in io.Reader, out, err io.WriteCloser, tty bool) error { … }

func fakeServer(t *testing.T, requestReceived chan struct{ … }

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

type fakeUpgrader …

func (u *fakeUpgrader) RoundTrip(req *http.Request) (*http.Response, error) { … }

func (u *fakeUpgrader) NewConnection(resp *http.Response) (httpstream.Connection, error) { … }

type fakeConnection …

// Dial is the common functionality between any stream based upgrader, regardless of protocol.
// This method ensures that someone can use a generic stream executor without being dependent
// on the core Kube client config behavior.
func TestDial(t *testing.T) { … }