frames

package
v0.0.0-...-431b911 Latest Latest
Warning

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

 Go to latest Published: Nov 7, 2015 License: BSD-2-Clause Imports: 8 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ReadFrame 

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

ReadFrame reads and parses a frame from reader.

Types

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
}

func (*GOAWAY) Compress 

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

func (*GOAWAY) Decompress 

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

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 NOOP 

type NOOP struct{}

func (*NOOP) Compress 

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

func (*NOOP) Decompress 

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

func (*NOOP) Name 

func (frame *NOOP) Name() string

func (*NOOP) ReadFrom 

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

func (*NOOP) String 

func (frame *NOOP) String() string

func (*NOOP) WriteTo 

func (frame *NOOP) 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
	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 WINDOW_UPDATE 

type WINDOW_UPDATE struct {
	StreamID        common.StreamID
	DeltaWindowSize uint32
}

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)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.