type google.golang.org/grpc/internal/transport.http2Server

32 uses

	google.golang.org/grpc/internal/transport (current package)
		http2_server.go#L65: type http2Server struct {
		http2_server.go#L213: 	t := &http2Server{
		http2_server.go#L304: func (t *http2Server) operateHeaders(frame *http2.MetaHeadersFrame, handle func(*Stream), traceCtx func(context.Context, string) context.Context) (fatal bool) {
		http2_server.go#L455: func (t *http2Server) HandleStreams(handle func(*Stream), traceCtx func(context.Context, string) context.Context) {
		http2_server.go#L517: func (t *http2Server) getStream(f http2.Frame) (*Stream, bool) {
		http2_server.go#L535: func (t *http2Server) adjustWindow(s *Stream, n uint32) {
		http2_server.go#L545: func (t *http2Server) updateWindow(s *Stream, n uint32) {
		http2_server.go#L556: func (t *http2Server) updateFlowControl(n uint32) {
		http2_server.go#L578: func (t *http2Server) handleData(f *http2.DataFrame) {
		http2_server.go#L645: func (t *http2Server) handleRSTStream(f *http2.RSTStreamFrame) {
		http2_server.go#L660: func (t *http2Server) handleSettings(f *http2.SettingsFrame) {
		http2_server.go#L693: func (t *http2Server) handlePing(f *http2.PingFrame) {
		http2_server.go#L745: func (t *http2Server) handleWindowUpdate(f *http2.WindowUpdateFrame) {
		http2_server.go#L765: func (t *http2Server) checkForHeaderListSize(it interface{}) bool {
		http2_server.go#L783: func (t *http2Server) WriteHeader(s *Stream, md metadata.MD) error {
		http2_server.go#L803: func (t *http2Server) setResetPingStrikes() {
		http2_server.go#L807: func (t *http2Server) writeHeaderLocked(s *Stream) error {
		http2_server.go#L846: func (t *http2Server) WriteStatus(s *Stream, st *status.Status) error {
		http2_server.go#L910: func (t *http2Server) Write(s *Stream, hdr []byte, data []byte, opts *Options) error {
		http2_server.go#L955: func (t *http2Server) keepalive() {
		http2_server.go#L1052: func (t *http2Server) Close() error {
		http2_server.go#L1080: func (t *http2Server) deleteStream(s *Stream, eosReceived bool) {
		http2_server.go#L1105: func (t *http2Server) finishStream(s *Stream, rst bool, rstCode http2.ErrCode, hdr *headerFrame, eosReceived bool) {
		http2_server.go#L1124: func (t *http2Server) closeStream(s *Stream, rst bool, rstCode http2.ErrCode, eosReceived bool) {
		http2_server.go#L1136: func (t *http2Server) RemoteAddr() net.Addr {
		http2_server.go#L1140: func (t *http2Server) Drain() {
		http2_server.go#L1144: func (t *http2Server) drain(code http2.ErrCode, debugData []byte) {
		http2_server.go#L1158: func (t *http2Server) outgoingGoAwayHandler(g *goAway) (bool, error) {
		http2_server.go#L1211: func (t *http2Server) ChannelzMetric() *channelz.SocketInternalMetric {
		http2_server.go#L1235: func (t *http2Server) IncrMsgSent() {
		http2_server.go#L1240: func (t *http2Server) IncrMsgRecv() {
		http2_server.go#L1245: func (t *http2Server) getOutFlowWindow() int64 {