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

Go to main page

Versions in this module

v1

v1.1.0-alpha

Oct 31, 2017

v1.0.1

Oct 31, 2017

v1.0.0

Oct 16, 2017

Changes in this version

+ const ClientPreface

+ const NextProtoTLS

+ const TrailerPrefix

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

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

+ var ErrNoCachedConn = errors.New("http2: no cached connection was available")

+ 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 ConfigureServer(s *http.Server, conf *Server) error

+ func ConfigureTransport(t1 *http.Transport) error

+ func ValidTrailerHeader(name string) bool

+ type ClientConn struct

+ func (cc *ClientConn) CanTakeNewRequest() bool

+ func (cc *ClientConn) Ping(ctx context.Context) error

+ func (cc *ClientConn) RoundTrip(req *http.Request) (*http.Response, error)

+ type ClientConnPool interface

+ GetClientConn func(req *http.Request, addr string) (*ClientConn, error)

+ MarkDead func(*ClientConn)

+ 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 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 RoundTripOpt struct

+ OnlyCachedConn bool

+ type ServeConnOpts struct

+ BaseConfig *http.Server

+ Handler http.Handler

+ type Server struct

+ IdleTimeout time.Duration

+ MaxConcurrentStreams uint32

+ MaxHandlers int

+ MaxReadFrameSize uint32

+ MaxUploadBufferPerConnection int32

+ MaxUploadBufferPerStream int32

+ NewWriteScheduler func() WriteScheduler

+ PermitProhibitedCipherSuites bool

+ func (s *Server) ServeConn(c net.Conn, opts *ServeConnOpts)

+ 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) IsAck() bool

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

+ type StreamError struct

+ Cause error

+ Code ErrCode

+ StreamID uint32

+ func (e StreamError) Error() string

+ type Transport struct

+ AllowHTTP bool

+ ConnPool ClientConnPool

+ DialTLS func(network, addr string, cfg *tls.Config) (net.Conn, error)

+ DisableCompression bool

+ MaxHeaderListSize uint32

+ TLSClientConfig *tls.Config

+ func (t *Transport) CloseIdleConnections()

+ func (t *Transport) NewClientConn(c net.Conn) (*ClientConn, error)

+ func (t *Transport) RoundTrip(req *http.Request) (*http.Response, error)

+ func (t *Transport) RoundTripOpt(req *http.Request, opt RoundTripOpt) (*http.Response, error)

+ 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