frames

package
v0.0.12 Latest Latest
Warning

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

 Go to latest Published: May 8, 2016 License: Apache-2.0 Imports: 5 Imported by: 21

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FindDecoder 

func FindDecoder(frameType Type) func(flags byte, streamId uint32, payload []byte, context *DecodingContext) (Frame, error)

Types

type DataFrame 

type DataFrame struct {
	StreamId  uint32
	Data      []byte
	EndStream bool
}

func NewDataFrame 

func NewDataFrame(streamId uint32, data []byte, endStream bool) *DataFrame

func (*DataFrame) Encode 

func (f *DataFrame) Encode(context *EncodingContext) ([]byte, error)

func (*DataFrame) GetStreamId added in v0.0.6 

func (f *DataFrame) GetStreamId() uint32

func (*DataFrame) Type 

func (f *DataFrame) Type() Type

type DecodingContext 

type DecodingContext struct {
	// contains filtered or unexported fields
}

func NewDecodingContext 

func NewDecodingContext() *DecodingContext

type EncodingContext 

type EncodingContext struct {
	// contains filtered or unexported fields
}

func NewEncodingContext 

func NewEncodingContext() *EncodingContext

type ErrorCode added in v0.0.6 

type ErrorCode uint32
const (
	NO_ERROR            ErrorCode = 0x0
	PROTOCOL_ERROR      ErrorCode = 0x1
	INTERNAL_ERROR      ErrorCode = 0x2
	FLOW_CONTROL_ERROR  ErrorCode = 0x3
	SETTINGS_TIMEOUT    ErrorCode = 0x4
	STREAM_CLOSED       ErrorCode = 0x5
	FRAME_SIZE_ERROR    ErrorCode = 0x6
	REFUSED_STREAM      ErrorCode = 0x7
	CANCEL              ErrorCode = 0x8
	COMPRESSION_ERROR   ErrorCode = 0x9
	CONNECT_ERROR       ErrorCode = 0xa
	ENHANCE_YOUR_CALM   ErrorCode = 0xb
	INADEQUATE_SECURITY ErrorCode = 0xc
	HTTP_1_1_REQUIRED   ErrorCode = 0xd
)

func (ErrorCode) String added in v0.0.6 

func (e ErrorCode) String() string

type Flag 

type Flag byte
const (
	DATA_FLAG_END_STREAM Flag = 0x01
	DATA_FLAG_PADDED     Flag = 0x08
)
const (
	HEADERS_FLAG_END_STREAM  Flag = 0x01
	HEADERS_FLAG_END_HEADERS Flag = 0x04
	HEADERS_FLAG_PADDED      Flag = 0x08
	HEADERS_FLAG_PRIORITY    Flag = 0x20
)
const (
	PUSH_PROMISE_FLAG_END_HEADERS Flag = 0x04
	PUSH_PROMISE_FLAG_PADDED      Flag = 0x08
)
const (
	ACK Flag = 0x01
)
const (
	SETTINGS_FLAG_ACK Flag = 0x01
)

type Frame 

type Frame interface {
	Encode(*EncodingContext) ([]byte, error)
	Type() Type
	GetStreamId() uint32
}

func DecodeDataFrame 

func DecodeDataFrame(flags byte, streamId uint32, framePayload []byte, context *DecodingContext) (Frame, error)

func DecodeGoAwayFrame added in v0.0.6 

func DecodeGoAwayFrame(flags byte, streamId uint32, payload []byte, context *DecodingContext) (Frame, error)

func DecodeHeadersFrame 

func DecodeHeadersFrame(flags byte, streamId uint32, payload []byte, context *DecodingContext) (Frame, error)

func DecodePingFrame added in v0.0.9 

func DecodePingFrame(flags byte, streamId uint32, payload []byte, context *DecodingContext) (Frame, error)

func DecodePriorityFrame added in v0.0.7 

func DecodePriorityFrame(flags byte, streamId uint32, payload []byte, context *DecodingContext) (Frame, error)

func DecodePushPromiseFrame added in v0.0.7 

func DecodePushPromiseFrame(flags byte, streamId uint32, payload []byte, context *DecodingContext) (Frame, error)

func DecodeRstStreamFrame added in v0.0.6 

func DecodeRstStreamFrame(flags byte, streamId uint32, payload []byte, context *DecodingContext) (Frame, error)

func DecodeSettingsFrame 

func DecodeSettingsFrame(flags byte, streamId uint32, payload []byte, context *DecodingContext) (Frame, error)

func DecodeWindowUpdateFrame added in v0.0.6 

func DecodeWindowUpdateFrame(flags byte, streamId uint32, payload []byte, context *DecodingContext) (Frame, error)

type FrameHeader 

type FrameHeader struct {
	Length     uint32
	HeaderType Type
	Flags      byte
	StreamId   uint32
}

func DecodeHeader 

func DecodeHeader(data []byte) *FrameHeader

type GoAwayFrame added in v0.0.6 

type GoAwayFrame struct {
	StreamId     uint32
	LastStreamId uint32
	ErrorCode    ErrorCode
}

func NewGoAwayFrame added in v0.0.6 

func NewGoAwayFrame(streamId uint32, lastStreamId uint32, errorCode ErrorCode) *GoAwayFrame

func (*GoAwayFrame) Encode added in v0.0.6 

func (f *GoAwayFrame) Encode(context *EncodingContext) ([]byte, error)

func (*GoAwayFrame) GetStreamId added in v0.0.6 

func (f *GoAwayFrame) GetStreamId() uint32

func (*GoAwayFrame) Type added in v0.0.6 

func (f *GoAwayFrame) Type() Type

type HeadersFrame 

type HeadersFrame struct {
	StreamId   uint32
	EndStream  bool
	EndHeaders bool
	Priority   bool
	Headers    []hpack.HeaderField
}

func NewHeadersFrame 

func NewHeadersFrame(streamId uint32, headers []hpack.HeaderField) *HeadersFrame

func (*HeadersFrame) Encode 

func (f *HeadersFrame) Encode(context *EncodingContext) ([]byte, error)

func (*HeadersFrame) GetStreamId added in v0.0.6 

func (f *HeadersFrame) GetStreamId() uint32

func (*HeadersFrame) Type 

func (f *HeadersFrame) Type() Type

type PingFrame added in v0.0.9 

type PingFrame struct {
	StreamId uint32
	Payload  uint64
	Ack      bool
}

func NewPingFrame added in v0.0.9 

func NewPingFrame(streamId uint32, payload uint64, ack bool) *PingFrame

func (*PingFrame) Encode added in v0.0.9 

func (f *PingFrame) Encode(context *EncodingContext) ([]byte, error)

func (*PingFrame) GetStreamId added in v0.0.9 

func (f *PingFrame) GetStreamId() uint32

func (*PingFrame) Type added in v0.0.9 

func (f *PingFrame) Type() Type

type PriorityFrame added in v0.0.7 

type PriorityFrame struct {
	StreamId           uint32
	StreamDependencyId uint32
	Weight             uint8
	Exclusive          bool
}

func NewPriorityFrame added in v0.0.7 

func NewPriorityFrame(streamId uint32, streamDependencyId uint32, weight uint8, exclusive bool) *PriorityFrame

func (*PriorityFrame) Encode added in v0.0.7 

func (f *PriorityFrame) Encode(context *EncodingContext) ([]byte, error)

func (*PriorityFrame) GetStreamId added in v0.0.7 

func (f *PriorityFrame) GetStreamId() uint32

func (*PriorityFrame) Type added in v0.0.7 

func (f *PriorityFrame) Type() Type

type PushPromiseFrame added in v0.0.7 

type PushPromiseFrame struct {
	StreamId         uint32
	EndHeaders       bool
	PromisedStreamId uint32
	Headers          []hpack.HeaderField
}

func NewPushPromiseFrame added in v0.0.7 

func NewPushPromiseFrame(streamId uint32, promisedStreamId uint32, headers []hpack.HeaderField) *PushPromiseFrame

func (*PushPromiseFrame) Encode added in v0.0.7 

func (f *PushPromiseFrame) Encode(context *EncodingContext) ([]byte, error)

func (*PushPromiseFrame) GetStreamId added in v0.0.7 

func (f *PushPromiseFrame) GetStreamId() uint32

func (*PushPromiseFrame) Type added in v0.0.7 

func (f *PushPromiseFrame) Type() Type

type RstStreamFrame added in v0.0.6 

type RstStreamFrame struct {
	StreamId  uint32
	ErrorCode ErrorCode
}

func NewRstStreamFrame added in v0.0.6 

func NewRstStreamFrame(streamId uint32, errorCode ErrorCode) *RstStreamFrame

func (*RstStreamFrame) Encode added in v0.0.6 

func (f *RstStreamFrame) Encode(context *EncodingContext) ([]byte, error)

func (*RstStreamFrame) GetStreamId added in v0.0.6 

func (f *RstStreamFrame) GetStreamId() uint32

func (*RstStreamFrame) Type added in v0.0.6 

func (f *RstStreamFrame) Type() Type

type Setting 

type Setting uint16
const (
	SETTINGS_HEADER_TABLE_SIZE      Setting = 0x01
	SETTINGS_ENABLE_PUSH            Setting = 0x02
	SETTINGS_MAX_CONCURRENT_STREAMS Setting = 0x03
	SETTINGS_INITIAL_WINDOW_SIZE    Setting = 0x04
	SETTINGS_MAX_FRAME_SIZE         Setting = 0x05
	SETTINGS_MAX_HEADER_LIST_SIZE   Setting = 0x06
)

func (Setting) Get added in v0.0.6 

func (s Setting) Get(f *SettingsFrame) uint32

func (Setting) IsSet added in v0.0.6 

func (s Setting) IsSet(f *SettingsFrame) bool

func (Setting) String 

func (s Setting) String() string

type SettingsFrame 

type SettingsFrame struct {
	StreamId uint32
	Ack      bool
	Settings map[Setting]uint32
}

func NewSettingsFrame 

func NewSettingsFrame(streamId uint32, ack bool) *SettingsFrame

func (*SettingsFrame) Encode 

func (f *SettingsFrame) Encode(context *EncodingContext) ([]byte, error)

func (*SettingsFrame) GetStreamId added in v0.0.6 

func (f *SettingsFrame) GetStreamId() uint32

func (*SettingsFrame) Type 

func (f *SettingsFrame) Type() Type

type Type 

type Type byte
const (
	DATA_TYPE          Type = 0x00
	HEADERS_TYPE       Type = 0x01
	PRIORITY_TYPE      Type = 0x02
	RST_STREAM_TYPE    Type = 0x03
	SETTINGS_TYPE      Type = 0x04
	PUSH_PROMISE_TYPE  Type = 0x05
	PING_TYPE          Type = 0x06
	GOAWAY_TYPE        Type = 0x07
	WINDOW_UPDATE_TYPE Type = 0x08
)

func AllFrameTypes added in v0.0.11 

func AllFrameTypes() []Type

func FrameNameToType added in v0.0.11 

func FrameNameToType(name string) (Type, bool)

func (Type) String added in v0.0.11 

func (t Type) String() string

type WindowUpdateFrame added in v0.0.6 

type WindowUpdateFrame struct {
	StreamId            uint32
	WindowSizeIncrement uint32
}

func NewWindowUpdateFrame added in v0.0.6 

func NewWindowUpdateFrame(streamId uint32, windowSizeIncrement uint32) *WindowUpdateFrame

func (*WindowUpdateFrame) Encode added in v0.0.6 

func (f *WindowUpdateFrame) Encode(context *EncodingContext) ([]byte, error)

func (*WindowUpdateFrame) GetStreamId added in v0.0.6 

func (f *WindowUpdateFrame) GetStreamId() uint32

func (*WindowUpdateFrame) Type added in v0.0.6 

func (f *WindowUpdateFrame) Type() Type

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.