Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

http2

package module

Go to main page

Versions in this module

v0

v0.1.8

Jun 30, 2023

v0.1.7

May 15, 2023

Changes in this version

+ func Record(ti traceinfo.TraceInfo, event stats.Event, err error)

v0.1.6

May 5, 2023

Changes in this version

+ func NewResponseWriter(conn network.Conn) (network.ExtWriter, error)

v0.1.5

Feb 10, 2023

v0.1.4

Jan 20, 2023

v0.1.3

Jan 18, 2023

v0.1.2

Jan 13, 2023

v0.1.1

Dec 7, 2022

v0.1.0

Dec 7, 2022

v0.0.1

Dec 7, 2022

Changes in this version

+ const ClientPreface

+ const Name

+ const NextProtoTLS

+ const Version

+ var DebugGoroutines = os.Getenv("DEBUG_HTTP2_GOROUTINES") == "1"

+ var ErrFrameTooLarge = errors.New("http2: frame too large")

+ var ErrPushLimitReached = errors.New("http2: push would exceed peer's SETTINGS_MAX_CONCURRENT_STREAMS")

+ var ErrRecursivePush = errors.New("http2: recursive push not allowed")

+ var VerboseLogs bool

+ func NewHostClient(c *config.ClientConfig) client.HostClient

+ type BaseEngine struct

+ Core suite.Core

+ func (b *BaseEngine) AcquireReqCtx() *app.RequestContext

+ func (b *BaseEngine) ReleaseReqCtx(ctx *app.RequestContext)

+ type ClientConnState struct

+ Closed bool

+ Closing bool

+ LastIdle time.Time

+ MaxConcurrentStreams uint32

+ StreamsActive int

+ StreamsPending int

+ StreamsReserved int

+ type CloseWithoutResetBuffer interface

+ CloseNoResetBuffer func() error

+ type ConnectionError ErrCode

+ func (e ConnectionError) Error() string

+ type ContinuationFrame struct

+ func (f *ContinuationFrame) HeaderBlockFragment() []byte

+ func (f *ContinuationFrame) HeadersEnded() bool

+ type DataFrame struct

+ func (f *DataFrame) Data() []byte

+ func (f *DataFrame) StreamEnded() bool

+ type ErrCode uint32

+ const ErrCodeCancel

+ const ErrCodeCompression

+ const ErrCodeConnect

+ const ErrCodeEnhanceYourCalm

+ const ErrCodeFlowControl

+ const ErrCodeFrameSize

+ const ErrCodeHTTP11Required

+ const ErrCodeInadequateSecurity

+ const ErrCodeInternal

+ const ErrCodeNo

+ const ErrCodeProtocol

+ const ErrCodeRefusedStream

+ const ErrCodeSettingsTimeout

+ const ErrCodeStreamClosed

+ func (e ErrCode) String() string

+ type Flags uint8

+ const FlagContinuationEndHeaders

+ const FlagDataEndStream

+ const FlagDataPadded

+ const FlagHeadersEndHeaders

+ const FlagHeadersEndStream

+ const FlagHeadersPadded

+ const FlagHeadersPriority

+ const FlagPingAck

+ const FlagPushPromiseEndHeaders

+ const FlagPushPromisePadded

+ const FlagSettingsAck

+ func (f Flags) Has(v Flags) bool

+ type Frame interface

+ Header func() FrameHeader

+ type FrameHeader struct

+ Flags Flags

+ Length uint32

+ StreamID uint32

+ Type FrameType

+ func ReadFrameHeader(r io.Reader) (FrameHeader, error)

+ func (h FrameHeader) Header() FrameHeader

+ func (h FrameHeader) String() string

+ type FrameType uint8

+ const FrameContinuation

+ const FrameData

+ const FrameGoAway

+ const FrameHeaders

+ const FramePing

+ const FramePriority

+ const FramePushPromise

+ const FrameRSTStream

+ const FrameSettings

+ const FrameWindowUpdate

+ func (t FrameType) String() string

+ type FrameWriteRequest struct

+ func (wr FrameWriteRequest) Consume(n int32) (FrameWriteRequest, FrameWriteRequest, int)

+ func (wr FrameWriteRequest) DataSize() int

+ func (wr FrameWriteRequest) StreamID() uint32

+ func (wr FrameWriteRequest) String() string

+ type Framer struct

+ AllowIllegalReads bool

+ AllowIllegalWrites bool

+ MaxHeaderListSize uint32

+ ReadMetaHeaders *hpack.Decoder

+ func NewFramer(w io.Writer, r io.Reader) *Framer

+ func (f *Framer) WriteContinuation(streamID uint32, endHeaders bool, headerBlockFragment []byte) error

+ func (f *Framer) WriteData(streamID uint32, endStream bool, data []byte) error

+ func (f *Framer) WriteDataPadded(streamID uint32, endStream bool, data, pad []byte) error

+ func (f *Framer) WriteGoAway(maxStreamID uint32, code ErrCode, debugData []byte) error

+ func (f *Framer) WriteHeaders(p HeadersFrameParam) error

+ func (f *Framer) WritePing(ack bool, data [8]byte) error

+ func (f *Framer) WritePriority(streamID uint32, p PriorityParam) error

+ func (f *Framer) WritePushPromise(p PushPromiseParam) error

+ func (f *Framer) WriteRSTStream(streamID uint32, code ErrCode) error

+ func (f *Framer) WriteRawFrame(t FrameType, flags Flags, streamID uint32, payload []byte) error

+ func (f *Framer) WriteSettings(settings ...Setting) error

+ func (f *Framer) WriteSettingsAck() error

+ func (f *Framer) WriteWindowUpdate(streamID, incr uint32) error

+ func (fr *Framer) ErrorDetail() error

+ func (fr *Framer) ReadFrame() (Frame, error)

+ func (fr *Framer) SetMaxReadFrameSize(v uint32)

+ func (fr *Framer) SetReuseFrames()

+ type GoAwayError struct

+ DebugData string

+ ErrCode ErrCode

+ LastStreamID uint32

+ func (e GoAwayError) Error() string

+ type GoAwayFrame struct

+ ErrCode ErrCode

+ LastStreamID uint32

+ func (f *GoAwayFrame) DebugData() []byte

+ type HeadersFrame struct

+ Priority PriorityParam

+ func (f *HeadersFrame) HasPriority() bool

+ func (f *HeadersFrame) HeaderBlockFragment() []byte

+ func (f *HeadersFrame) HeadersEnded() bool

+ func (f *HeadersFrame) StreamEnded() bool

+ type HeadersFrameParam struct

+ BlockFragment []byte

+ EndHeaders bool

+ EndStream bool

+ PadLength uint8

+ Priority PriorityParam

+ StreamID uint32

+ type HostClient struct

+ Addr string

+ IsTLS bool

+ func (hc *HostClient) CloseIdleConnections()

+ func (hc *HostClient) ConnectionCount() int

+ func (hc *HostClient) Do(ctx context.Context, req *protocol.Request, rsp *protocol.Response) error

+ func (hc *HostClient) Get(ctx context.Context, dst []byte, url string) (statusCode int, body []byte, err error)

+ func (hc *HostClient) SetDynamicConfig(dc *client.DynamicConfig)

+ func (hc *HostClient) ShouldRemove() bool

+ type MetaHeadersFrame struct

+ Fields []hpack.HeaderField

+ Truncated bool

+ func (mh *MetaHeadersFrame) PseudoFields() []hpack.HeaderField

+ func (mh *MetaHeadersFrame) PseudoValue(pseudo string) string

+ func (mh *MetaHeadersFrame) RegularFields() []hpack.HeaderField

+ type OpenStreamOptions struct

+ PusherID uint32

+ type PingFrame struct

+ Data [8]byte

+ func (f *PingFrame) IsAck() bool

+ type PriorityFrame struct

+ type PriorityParam struct

+ Exclusive bool

+ StreamDep uint32

+ Weight uint8

+ func (p PriorityParam) IsZero() bool

+ type PriorityWriteSchedulerConfig struct

+ MaxClosedNodesInTree int

+ MaxIdleNodesInTree int

+ ThrottleOutOfOrderWrites bool

+ type PushPromiseFrame struct

+ PromiseID uint32

+ func (f *PushPromiseFrame) HeaderBlockFragment() []byte

+ func (f *PushPromiseFrame) HeadersEnded() bool

+ type PushPromiseParam struct

+ BlockFragment []byte

+ EndHeaders bool

+ PadLength uint8

+ PromiseID uint32

+ StreamID uint32

+ type RSTStreamFrame struct

+ ErrCode ErrCode

+ type Server struct

+ IdleTimeout time.Duration

+ MaxConcurrentStreams uint32

+ MaxHandlers int

+ MaxReadFrameSize uint32

+ MaxUploadBufferPerConnection int32

+ MaxUploadBufferPerStream int32

+ NewWriteScheduler func() WriteScheduler

+ PermitProhibitedCipherSuites bool

+ func (s *Server) Serve(ctx context.Context, c network.Conn) error

+ type Setting struct

+ ID SettingID

+ Val uint32

+ func (s Setting) String() string

+ func (s Setting) Valid() error

+ type SettingID uint16

+ const SettingEnablePush

+ const SettingHeaderTableSize

+ const SettingInitialWindowSize

+ const SettingMaxConcurrentStreams

+ const SettingMaxFrameSize

+ const SettingMaxHeaderListSize

+ func (s SettingID) String() string

+ type SettingsFrame struct

+ func (f *SettingsFrame) ForeachSetting(fn func(Setting) error) error

+ func (f *SettingsFrame) HasDuplicates() bool

+ func (f *SettingsFrame) IsAck() bool

+ func (f *SettingsFrame) NumSettings() int

+ func (f *SettingsFrame) Setting(i int) Setting

+ func (f *SettingsFrame) Value(id SettingID) (v uint32, ok bool)

+ type StreamError struct

+ Cause error

+ Code ErrCode

+ StreamID uint32

+ func (e StreamError) Error() string

+ type Trailer = []struct

+ type UnknownFrame struct

+ func (f *UnknownFrame) Payload() []byte

+ type WindowUpdateFrame struct

+ Increment uint32

+ type WriteScheduler interface

+ AdjustStream func(streamID uint32, priority PriorityParam)

+ CloseStream func(streamID uint32)

+ OpenStream func(streamID uint32, options OpenStreamOptions)

+ Pop func() (wr FrameWriteRequest, ok bool)

+ Push func(wr FrameWriteRequest)

+ func NewPriorityWriteScheduler(cfg *PriorityWriteSchedulerConfig) WriteScheduler

+ func NewRandomWriteScheduler() WriteScheduler