frames

package
v0.0.0-...-b5edf18 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 17, 2016 License: BSD-2-Clause Imports: 9 Imported by: 0

Documentation

Overview

Package frames contains an implementation of the SPDY/3 frames.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ReadFrame

func ReadFrame(reader *bufio.Reader, subversion int) (frame common.Frame, err error)

ReadFrame reads and parses a frame from reader.

Types

type CREDENTIAL

type CREDENTIAL struct {
	Slot         uint16
	Proof        []byte
	Certificates []*x509.Certificate
}

func (*CREDENTIAL) Compress

func (frame *CREDENTIAL) Compress(comp common.Compressor) error

func (*CREDENTIAL) Decompress

func (frame *CREDENTIAL) Decompress(decomp common.Decompressor) error

func (*CREDENTIAL) Name

func (frame *CREDENTIAL) Name() string

func (*CREDENTIAL) ReadFrom

func (frame *CREDENTIAL) ReadFrom(reader io.Reader) (int64, error)

func (*CREDENTIAL) String

func (frame *CREDENTIAL) String() string

func (*CREDENTIAL) WriteTo

func (frame *CREDENTIAL) WriteTo(writer io.Writer) (int64, error)

type DATA

type DATA struct {
	StreamID common.StreamID
	Flags    common.Flags
	Data     []byte
}

func (*DATA) Compress

func (frame *DATA) Compress(comp common.Compressor) error

func (*DATA) Decompress

func (frame *DATA) Decompress(decomp common.Decompressor) error

func (*DATA) Name

func (frame *DATA) Name() string

func (*DATA) ReadFrom

func (frame *DATA) ReadFrom(reader io.Reader) (int64, error)

func (*DATA) String

func (frame *DATA) String() string

func (*DATA) WriteTo

func (frame *DATA) WriteTo(writer io.Writer) (int64, error)

type GOAWAY

type GOAWAY struct {
	LastGoodStreamID common.StreamID
	Status           common.StatusCode
}

func (*GOAWAY) Compress

func (frame *GOAWAY) Compress(comp common.Compressor) error

func (*GOAWAY) Decompress

func (frame *GOAWAY) Decompress(decomp common.Decompressor) error

func (*GOAWAY) Error

func (frame *GOAWAY) Error() string

func (*GOAWAY) Name

func (frame *GOAWAY) Name() string

func (*GOAWAY) ReadFrom

func (frame *GOAWAY) ReadFrom(reader io.Reader) (int64, error)

func (*GOAWAY) String

func (frame *GOAWAY) String() string

func (*GOAWAY) WriteTo

func (frame *GOAWAY) WriteTo(writer io.Writer) (int64, error)

type HEADERS

type HEADERS struct {
	Flags    common.Flags
	StreamID common.StreamID
	Header   http.Header
	// contains filtered or unexported fields
}

func (*HEADERS) Compress

func (frame *HEADERS) Compress(com common.Compressor) error

func (*HEADERS) Decompress

func (frame *HEADERS) Decompress(decom common.Decompressor) error

func (*HEADERS) Name

func (frame *HEADERS) Name() string

func (*HEADERS) ReadFrom

func (frame *HEADERS) ReadFrom(reader io.Reader) (int64, error)

func (*HEADERS) String

func (frame *HEADERS) String() string

func (*HEADERS) WriteTo

func (frame *HEADERS) WriteTo(writer io.Writer) (int64, error)

type PING

type PING struct {
	PingID uint32
}

func (*PING) Compress

func (frame *PING) Compress(comp common.Compressor) error

func (*PING) Decompress

func (frame *PING) Decompress(decomp common.Decompressor) error

func (*PING) Name

func (frame *PING) Name() string

func (*PING) ReadFrom

func (frame *PING) ReadFrom(reader io.Reader) (int64, error)

func (*PING) String

func (frame *PING) String() string

func (*PING) WriteTo

func (frame *PING) WriteTo(writer io.Writer) (int64, error)

type RST_STREAM

type RST_STREAM struct {
	StreamID common.StreamID
	Status   common.StatusCode
}

func (*RST_STREAM) Compress

func (frame *RST_STREAM) Compress(comp common.Compressor) error

func (*RST_STREAM) Decompress

func (frame *RST_STREAM) Decompress(decomp common.Decompressor) error

func (*RST_STREAM) Error

func (frame *RST_STREAM) Error() string

func (*RST_STREAM) Name

func (frame *RST_STREAM) Name() string

func (*RST_STREAM) ReadFrom

func (frame *RST_STREAM) ReadFrom(reader io.Reader) (int64, error)

func (*RST_STREAM) String

func (frame *RST_STREAM) String() string

func (*RST_STREAM) WriteTo

func (frame *RST_STREAM) WriteTo(writer io.Writer) (int64, error)

type SETTINGS

type SETTINGS struct {
	Flags    common.Flags
	Settings common.Settings
}

func (*SETTINGS) Add

func (frame *SETTINGS) Add(flags common.Flags, id uint32, value uint32)

func (*SETTINGS) Compress

func (frame *SETTINGS) Compress(comp common.Compressor) error

func (*SETTINGS) Decompress

func (frame *SETTINGS) Decompress(decomp common.Decompressor) error

func (*SETTINGS) Name

func (frame *SETTINGS) Name() string

func (*SETTINGS) ReadFrom

func (frame *SETTINGS) ReadFrom(reader io.Reader) (int64, error)

func (*SETTINGS) String

func (frame *SETTINGS) String() string

func (*SETTINGS) WriteTo

func (frame *SETTINGS) WriteTo(writer io.Writer) (int64, error)

type SYN_REPLY

type SYN_REPLY struct {
	Flags    common.Flags
	StreamID common.StreamID
	Header   http.Header
	// contains filtered or unexported fields
}

func (*SYN_REPLY) Compress

func (frame *SYN_REPLY) Compress(com common.Compressor) error

func (*SYN_REPLY) Decompress

func (frame *SYN_REPLY) Decompress(decom common.Decompressor) error

func (*SYN_REPLY) Name

func (frame *SYN_REPLY) Name() string

func (*SYN_REPLY) ReadFrom

func (frame *SYN_REPLY) ReadFrom(reader io.Reader) (int64, error)

func (*SYN_REPLY) String

func (frame *SYN_REPLY) String() string

func (*SYN_REPLY) WriteTo

func (frame *SYN_REPLY) WriteTo(writer io.Writer) (int64, error)

type SYN_STREAM

type SYN_STREAM struct {
	Flags         common.Flags
	StreamID      common.StreamID
	AssocStreamID common.StreamID
	Priority      common.Priority
	Slot          byte
	Header        http.Header
	// contains filtered or unexported fields
}

func (*SYN_STREAM) Compress

func (frame *SYN_STREAM) Compress(com common.Compressor) error

func (*SYN_STREAM) Decompress

func (frame *SYN_STREAM) Decompress(decom common.Decompressor) error

func (*SYN_STREAM) Name

func (frame *SYN_STREAM) Name() string

func (*SYN_STREAM) ReadFrom

func (frame *SYN_STREAM) ReadFrom(reader io.Reader) (int64, error)

func (*SYN_STREAM) String

func (frame *SYN_STREAM) String() string

func (*SYN_STREAM) WriteTo

func (frame *SYN_STREAM) WriteTo(writer io.Writer) (int64, error)

type SYN_STREAMV3_1

type SYN_STREAMV3_1 struct {
	Flags         common.Flags
	StreamID      common.StreamID
	AssocStreamID common.StreamID
	Priority      common.Priority
	Header        http.Header
	// contains filtered or unexported fields
}

SPDY/3.1

func (*SYN_STREAMV3_1) Compress

func (frame *SYN_STREAMV3_1) Compress(com common.Compressor) error

func (*SYN_STREAMV3_1) Decompress

func (frame *SYN_STREAMV3_1) Decompress(decom common.Decompressor) error

func (*SYN_STREAMV3_1) Name

func (frame *SYN_STREAMV3_1) Name() string

func (*SYN_STREAMV3_1) ReadFrom

func (frame *SYN_STREAMV3_1) ReadFrom(reader io.Reader) (int64, error)

func (*SYN_STREAMV3_1) String

func (frame *SYN_STREAMV3_1) String() string

func (*SYN_STREAMV3_1) WriteTo

func (frame *SYN_STREAMV3_1) WriteTo(writer io.Writer) (int64, error)

type WINDOW_UPDATE

type WINDOW_UPDATE struct {
	StreamID        common.StreamID
	DeltaWindowSize uint32
	// contains filtered or unexported fields
}

func (*WINDOW_UPDATE) Compress

func (frame *WINDOW_UPDATE) Compress(comp common.Compressor) error

func (*WINDOW_UPDATE) Decompress

func (frame *WINDOW_UPDATE) Decompress(decomp common.Decompressor) error

func (*WINDOW_UPDATE) Name

func (frame *WINDOW_UPDATE) Name() string

func (*WINDOW_UPDATE) ReadFrom

func (frame *WINDOW_UPDATE) ReadFrom(reader io.Reader) (int64, error)

func (*WINDOW_UPDATE) String

func (frame *WINDOW_UPDATE) String() string

func (*WINDOW_UPDATE) WriteTo

func (frame *WINDOW_UPDATE) WriteTo(writer io.Writer) (int64, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL