kubernetes/staging/src/k8s.io/kubelet/pkg/cri/streaming/portforward/httpstream_test.go

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

type fakeConn …

func (*fakeConn) CreateStream(headers http.Header) (httpstream.Stream, error) { … }

func (*fakeConn) Close() error                                                { … }

func (*fakeConn) CloseChan() <-chan bool                                      { … }

func (*fakeConn) SetIdleTimeout(timeout time.Duration)                        { … }

func (f *fakeConn) RemoveStreams(streams ...httpstream.Stream)                { … }

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

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

type fakeHTTPStream …

func newFakeHTTPStream() *fakeHTTPStream { … }

var _ …

func (s *fakeHTTPStream) Read(data []byte) (int, error) { … }

func (s *fakeHTTPStream) Write(data []byte) (int, error) { … }

func (s *fakeHTTPStream) Close() error { … }

func (s *fakeHTTPStream) Reset() error { … }

func (s *fakeHTTPStream) Headers() http.Header { … }

func (s *fakeHTTPStream) Identifier() uint32 { … }