kubernetes/vendor/google.golang.org/grpc/internal/transport/handler_server.go

// NewServerHandlerTransport returns a ServerTransport handling gRPC from
// inside an http.Handler, or writes an HTTP error to w and returns an error.
// It requires that the http Server supports HTTP/2.
func NewServerHandlerTransport(w http.ResponseWriter, r *http.Request, stats []stats.Handler) (ServerTransport, error) { … }

type serverHandlerTransport …

func (ht *serverHandlerTransport) Close(err error) { … }

func (ht *serverHandlerTransport) Peer() *peer.Peer { … }

type strAddr …

func (a strAddr) Network() string { … }

func (a strAddr) String() string { … }

// do runs fn in the ServeHTTP goroutine.
func (ht *serverHandlerTransport) do(fn func()) error { … }

func (ht *serverHandlerTransport) WriteStatus(s *Stream, st *status.Status) error { … }

// writePendingHeaders sets common and custom headers on the first
// write call (Write, WriteHeader, or WriteStatus)
func (ht *serverHandlerTransport) writePendingHeaders(s *Stream) { … }

// writeCommonHeaders sets common headers on the first write
// call (Write, WriteHeader, or WriteStatus).
func (ht *serverHandlerTransport) writeCommonHeaders(s *Stream) { … }

// writeCustomHeaders sets custom headers set on the stream via SetHeader
// on the first write call (Write, WriteHeader, or WriteStatus)
func (ht *serverHandlerTransport) writeCustomHeaders(s *Stream) { … }

func (ht *serverHandlerTransport) Write(s *Stream, hdr []byte, data []byte, opts *Options) error { … }

func (ht *serverHandlerTransport) WriteHeader(s *Stream, md metadata.MD) error { … }

func (ht *serverHandlerTransport) HandleStreams(ctx context.Context, startStream func(*Stream)) { … }

func (ht *serverHandlerTransport) runStream() { … }

func (ht *serverHandlerTransport) IncrMsgSent() { … }

func (ht *serverHandlerTransport) IncrMsgRecv() { … }

func (ht *serverHandlerTransport) Drain(debugData string) { … }

// mapRecvMsgError returns the non-nil err into the appropriate
// error value as expected by callers of *grpc.parser.recvMsg.
// In particular, in can only be:
//   - io.EOF
//   - io.ErrUnexpectedEOF
//   - of type transport.ConnectionError
//   - an error from the status package
func mapRecvMsgError(err error) error { … }