const frameHeaderLen … var padZeros … type FrameType … const FrameData … const FrameHeaders … const FramePriority … const FrameRSTStream … const FrameSettings … const FramePushPromise … const FramePing … const FrameGoAway … const FrameWindowUpdate … const FrameContinuation … var frameName … func (t FrameType) String() string { … } type Flags … // Has reports whether f contains all (0 or more) flags in v. func (f Flags) Has(v Flags) bool { … } const FlagDataEndStream … const FlagDataPadded … const FlagHeadersEndStream … const FlagHeadersEndHeaders … const FlagHeadersPadded … const FlagHeadersPriority … const FlagSettingsAck … const FlagPingAck … const FlagContinuationEndHeaders … const FlagPushPromiseEndHeaders … const FlagPushPromisePadded … var flagName … type frameParser … var frameParsers … func typeFrameParser(t FrameType) frameParser { … } type FrameHeader … // Header returns h. It exists so FrameHeaders can be embedded in other // specific frame types and implement the Frame interface. func (h FrameHeader) Header() FrameHeader { … } func (h FrameHeader) String() string { … } func (h FrameHeader) writeDebug(buf *bytes.Buffer) { … } func (h *FrameHeader) checkValid() { … } func (h *FrameHeader) invalidate() { … } var fhBytes … // ReadFrameHeader reads 9 bytes from r and returns a FrameHeader. // Most users should use Framer.ReadFrame instead. func ReadFrameHeader(r io.Reader) (FrameHeader, error) { … } func readFrameHeader(buf []byte, r io.Reader) (FrameHeader, error) { … } type Frame … type Framer … func (fr *Framer) maxHeaderListSize() uint32 { … } func (f *Framer) startWrite(ftype FrameType, flags Flags, streamID uint32) { … } func (f *Framer) endWrite() error { … } func (f *Framer) logWrite() { … } func (f *Framer) writeByte(v byte) { … } func (f *Framer) writeBytes(v []byte) { … } func (f *Framer) writeUint16(v uint16) { … } func (f *Framer) writeUint32(v uint32) { … } const minMaxFrameSize … const maxFrameSize … // SetReuseFrames allows the Framer to reuse Frames. // If called on a Framer, Frames returned by calls to ReadFrame are only // valid until the next call to ReadFrame. func (fr *Framer) SetReuseFrames() { … } type frameCache … func (fc *frameCache) getDataFrame() *DataFrame { … } // NewFramer returns a Framer that writes frames to w and reads them from r. func NewFramer(w io.Writer, r io.Reader) *Framer { … } // SetMaxReadFrameSize sets the maximum size of a frame // that will be read by a subsequent call to ReadFrame. // It is the caller's responsibility to advertise this // limit with a SETTINGS frame. func (fr *Framer) SetMaxReadFrameSize(v uint32) { … } // ErrorDetail returns a more detailed error of the last error // returned by Framer.ReadFrame. For instance, if ReadFrame // returns a StreamError with code PROTOCOL_ERROR, ErrorDetail // will say exactly what was invalid. ErrorDetail is not guaranteed // to return a non-nil value and like the rest of the http2 package, // its return value is not protected by an API compatibility promise. // ErrorDetail is reset after the next call to ReadFrame. func (fr *Framer) ErrorDetail() error { … } var ErrFrameTooLarge … // terminalReadFrameError reports whether err is an unrecoverable // error from ReadFrame and no other frames should be read. func terminalReadFrameError(err error) bool { … } // ReadFrame reads a single frame. The returned Frame is only valid // until the next call to ReadFrame. // // If the frame is larger than previously set with SetMaxReadFrameSize, the // returned error is ErrFrameTooLarge. Other errors may be of type // ConnectionError, StreamError, or anything else from the underlying // reader. // // If ReadFrame returns an error and a non-nil Frame, the Frame's StreamID // indicates the stream responsible for the error. func (fr *Framer) ReadFrame() (Frame, error) { … } // connError returns ConnectionError(code) but first // stashes away a public reason to the caller can optionally relay it // to the peer before hanging up on them. This might help others debug // their implementations. func (fr *Framer) connError(code ErrCode, reason string) error { … } // checkFrameOrder reports an error if f is an invalid frame to return // next from ReadFrame. Mostly it checks whether HEADERS and // CONTINUATION frames are contiguous. func (fr *Framer) checkFrameOrder(f Frame) error { … } type DataFrame … func (f *DataFrame) StreamEnded() bool { … } // Data returns the frame's data octets, not including any padding // size byte or padding suffix bytes. // The caller must not retain the returned memory past the next // call to ReadFrame. func (f *DataFrame) Data() []byte { … } func parseDataFrame(fc *frameCache, fh FrameHeader, countError func(string), payload []byte) (Frame, error) { … } var errStreamID … var errDepStreamID … var errPadLength … var errPadBytes … func validStreamIDOrZero(streamID uint32) bool { … } func validStreamID(streamID uint32) bool { … } // WriteData writes a DATA frame. // // It will perform exactly one Write to the underlying Writer. // It is the caller's responsibility not to violate the maximum frame size // and to not call other Write methods concurrently. func (f *Framer) WriteData(streamID uint32, endStream bool, data []byte) error { … } // WriteDataPadded writes a DATA frame with optional padding. // // If pad is nil, the padding bit is not sent. // The length of pad must not exceed 255 bytes. // The bytes of pad must all be zero, unless f.AllowIllegalWrites is set. // // It will perform exactly one Write to the underlying Writer. // It is the caller's responsibility not to violate the maximum frame size // and to not call other Write methods concurrently. func (f *Framer) WriteDataPadded(streamID uint32, endStream bool, data, pad []byte) error { … } // startWriteDataPadded is WriteDataPadded, but only writes the frame to the Framer's internal buffer. // The caller should call endWrite to flush the frame to the underlying writer. func (f *Framer) startWriteDataPadded(streamID uint32, endStream bool, data, pad []byte) error { … } type SettingsFrame … func parseSettingsFrame(_ *frameCache, fh FrameHeader, countError func(string), p []byte) (Frame, error) { … } func (f *SettingsFrame) IsAck() bool { … } func (f *SettingsFrame) Value(id SettingID) (v uint32, ok bool) { … } // Setting returns the setting from the frame at the given 0-based index. // The index must be >= 0 and less than f.NumSettings(). func (f *SettingsFrame) Setting(i int) Setting { … } func (f *SettingsFrame) NumSettings() int { … } // HasDuplicates reports whether f contains any duplicate setting IDs. func (f *SettingsFrame) HasDuplicates() bool { … } // ForeachSetting runs fn for each setting. // It stops and returns the first error. func (f *SettingsFrame) ForeachSetting(fn func(Setting) error) error { … } // WriteSettings writes a SETTINGS frame with zero or more settings // specified and the ACK bit not set. // // It will perform exactly one Write to the underlying Writer. // It is the caller's responsibility to not call other Write methods concurrently. func (f *Framer) WriteSettings(settings ...Setting) error { … } // WriteSettingsAck writes an empty SETTINGS frame with the ACK bit set. // // It will perform exactly one Write to the underlying Writer. // It is the caller's responsibility to not call other Write methods concurrently. func (f *Framer) WriteSettingsAck() error { … } type PingFrame … func (f *PingFrame) IsAck() bool { … } func parsePingFrame(_ *frameCache, fh FrameHeader, countError func(string), payload []byte) (Frame, error) { … } func (f *Framer) WritePing(ack bool, data [8]byte) error { … } type GoAwayFrame … // DebugData returns any debug data in the GOAWAY frame. Its contents // are not defined. // The caller must not retain the returned memory past the next // call to ReadFrame. func (f *GoAwayFrame) DebugData() []byte { … } func parseGoAwayFrame(_ *frameCache, fh FrameHeader, countError func(string), p []byte) (Frame, error) { … } func (f *Framer) WriteGoAway(maxStreamID uint32, code ErrCode, debugData []byte) error { … } type UnknownFrame … // Payload returns the frame's payload (after the header). It is not // valid to call this method after a subsequent call to // Framer.ReadFrame, nor is it valid to retain the returned slice. // The memory is owned by the Framer and is invalidated when the next // frame is read. func (f *UnknownFrame) Payload() []byte { … } func parseUnknownFrame(_ *frameCache, fh FrameHeader, countError func(string), p []byte) (Frame, error) { … } type WindowUpdateFrame … func parseWindowUpdateFrame(_ *frameCache, fh FrameHeader, countError func(string), p []byte) (Frame, error) { … } // WriteWindowUpdate writes a WINDOW_UPDATE frame. // The increment value must be between 1 and 2,147,483,647, inclusive. // If the Stream ID is zero, the window update applies to the // connection as a whole. func (f *Framer) WriteWindowUpdate(streamID, incr uint32) error { … } type HeadersFrame … func (f *HeadersFrame) HeaderBlockFragment() []byte { … } func (f *HeadersFrame) HeadersEnded() bool { … } func (f *HeadersFrame) StreamEnded() bool { … } func (f *HeadersFrame) HasPriority() bool { … } func parseHeadersFrame(_ *frameCache, fh FrameHeader, countError func(string), p []byte) (_ Frame, err error) { … } type HeadersFrameParam … // WriteHeaders writes a single HEADERS frame. // // This is a low-level header writing method. Encoding headers and // splitting them into any necessary CONTINUATION frames is handled // elsewhere. // // It will perform exactly one Write to the underlying Writer. // It is the caller's responsibility to not call other Write methods concurrently. func (f *Framer) WriteHeaders(p HeadersFrameParam) error { … } type PriorityFrame … type PriorityParam … func (p PriorityParam) IsZero() bool { … } func parsePriorityFrame(_ *frameCache, fh FrameHeader, countError func(string), payload []byte) (Frame, error) { … } // WritePriority writes a PRIORITY frame. // // It will perform exactly one Write to the underlying Writer. // It is the caller's responsibility to not call other Write methods concurrently. func (f *Framer) WritePriority(streamID uint32, p PriorityParam) error { … } type RSTStreamFrame … func parseRSTStreamFrame(_ *frameCache, fh FrameHeader, countError func(string), p []byte) (Frame, error) { … } // WriteRSTStream writes a RST_STREAM frame. // // It will perform exactly one Write to the underlying Writer. // It is the caller's responsibility to not call other Write methods concurrently. func (f *Framer) WriteRSTStream(streamID uint32, code ErrCode) error { … } type ContinuationFrame … func parseContinuationFrame(_ *frameCache, fh FrameHeader, countError func(string), p []byte) (Frame, error) { … } func (f *ContinuationFrame) HeaderBlockFragment() []byte { … } func (f *ContinuationFrame) HeadersEnded() bool { … } // WriteContinuation writes a CONTINUATION frame. // // It will perform exactly one Write to the underlying Writer. // It is the caller's responsibility to not call other Write methods concurrently. func (f *Framer) WriteContinuation(streamID uint32, endHeaders bool, headerBlockFragment []byte) error { … } type PushPromiseFrame … func (f *PushPromiseFrame) HeaderBlockFragment() []byte { … } func (f *PushPromiseFrame) HeadersEnded() bool { … } func parsePushPromise(_ *frameCache, fh FrameHeader, countError func(string), p []byte) (_ Frame, err error) { … } type PushPromiseParam … // WritePushPromise writes a single PushPromise Frame. // // As with Header Frames, This is the low level call for writing // individual frames. Continuation frames are handled elsewhere. // // It will perform exactly one Write to the underlying Writer. // It is the caller's responsibility to not call other Write methods concurrently. func (f *Framer) WritePushPromise(p PushPromiseParam) error { … } // WriteRawFrame writes a raw frame. This can be used to write // extension frames unknown to this package. func (f *Framer) WriteRawFrame(t FrameType, flags Flags, streamID uint32, payload []byte) error { … } func readByte(p []byte) (remain []byte, b byte, err error) { … } func readUint32(p []byte) (remain []byte, v uint32, err error) { … } type streamEnder … type headersEnder … type headersOrContinuation … type MetaHeadersFrame … // PseudoValue returns the given pseudo header field's value. // The provided pseudo field should not contain the leading colon. func (mh *MetaHeadersFrame) PseudoValue(pseudo string) string { … } // RegularFields returns the regular (non-pseudo) header fields of mh. // The caller does not own the returned slice. func (mh *MetaHeadersFrame) RegularFields() []hpack.HeaderField { … } // PseudoFields returns the pseudo header fields of mh. // The caller does not own the returned slice. func (mh *MetaHeadersFrame) PseudoFields() []hpack.HeaderField { … } func (mh *MetaHeadersFrame) checkPseudos() error { … } func (fr *Framer) maxHeaderStringLen() int { … } // readMetaFrame returns 0 or more CONTINUATION frames from fr and // merge them into the provided hf and returns a MetaHeadersFrame // with the decoded hpack values. func (fr *Framer) readMetaFrame(hf *HeadersFrame) (Frame, error) { … } func summarizeFrame(f Frame) string { … }
Codebase Browser
kubernetes