wire

package

Go to main page

Versions in this module

v0

v0.22.12

Jul 7, 2021

v0.22.11

Jul 7, 2021

v0.22.10

Jun 30, 2021

v0.22.9

Jun 23, 2021

v0.22.8

Jun 22, 2021

v0.22.7

Jun 8, 2021

v0.22.6

Jun 8, 2021

v0.22.5

Jun 8, 2021

v0.22.4

Jun 8, 2021

v0.22.3

Jun 2, 2021

v0.22.2

Jun 2, 2021

v0.22.1

Jun 2, 2021

v0.22.0

Jun 1, 2021

Changes in this version

+ var ErrInvalidReservedBits = errors.New("invalid reserved bits")

+ var ErrUnsupportedVersion = errors.New("unsupported version")

+ func Is0RTTPacket(b []byte) bool

+ func IsVersionNegotiationPacket(b []byte) bool

+ func ParseConnectionID(data []byte, shortHeaderConnIDLen int) (protocol.ConnectionID, error)

type AckFrame

+ ECNCE uint64

+ ECT0 uint64

+ ECT1 uint64

type ConnectionCloseFrame

+ FrameType uint64

+ IsApplicationError bool

+ type CryptoFrame struct

+ Data []byte

+ Offset protocol.ByteCount

+ func (f *CryptoFrame) Length(_ protocol.VersionNumber) protocol.ByteCount

+ func (f *CryptoFrame) MaxDataLen(maxSize protocol.ByteCount) protocol.ByteCount

+ func (f *CryptoFrame) MaybeSplitOffFrame(maxSize protocol.ByteCount, version protocol.VersionNumber) (*CryptoFrame, bool)

+ func (f *CryptoFrame) Write(b *bytes.Buffer, _ protocol.VersionNumber) error

+ type DataBlockedFrame struct

+ MaximumData protocol.ByteCount

+ func (f *DataBlockedFrame) Length(version protocol.VersionNumber) protocol.ByteCount

+ func (f *DataBlockedFrame) Write(b *bytes.Buffer, version protocol.VersionNumber) error

+ type DatagramFrame struct

+ Data []byte

+ DataLenPresent bool

+ func (f *DatagramFrame) Length(_ protocol.VersionNumber) protocol.ByteCount

+ func (f *DatagramFrame) MaxDataLen(maxSize protocol.ByteCount, version protocol.VersionNumber) protocol.ByteCount

+ func (f *DatagramFrame) Write(b *bytes.Buffer, _ protocol.VersionNumber) error

+ type ExtendedHeader struct

+ KeyPhase protocol.KeyPhaseBit

+ PacketNumber protocol.PacketNumber

+ PacketNumberLen protocol.PacketNumberLen

+ func (h *ExtendedHeader) GetLength(v protocol.VersionNumber) protocol.ByteCount

+ func (h *ExtendedHeader) Log(logger utils.Logger)

+ func (h *ExtendedHeader) ParsedLen() protocol.ByteCount

+ func (h *ExtendedHeader) Write(b *bytes.Buffer, ver protocol.VersionNumber) error

+ type FrameParser interface

+ ParseNext func(*bytes.Reader, protocol.EncryptionLevel) (Frame, error)

+ SetAckDelayExponent func(uint8)

+ func NewFrameParser(supportsDatagrams bool, v protocol.VersionNumber) FrameParser

+ type HandshakeDoneFrame struct

+ func (f *HandshakeDoneFrame) Length(_ protocol.VersionNumber) protocol.ByteCount

+ func (f *HandshakeDoneFrame) Write(b *bytes.Buffer, _ protocol.VersionNumber) error

type Header

+ Length protocol.ByteCount

+ func ParsePacket(data []byte, shortHeaderConnIDLen int) (*Header, []byte, []byte, error)

+ func ParseVersionNegotiationPacket(b *bytes.Reader) (*Header, []protocol.VersionNumber, error)

+ func (h *Header) PacketType() string

+ func (h *Header) ParseExtended(b *bytes.Reader, ver protocol.VersionNumber) (*ExtendedHeader, error)

+ func (h *Header) ParsedLen() protocol.ByteCount

type MaxDataFrame

+ MaximumData protocol.ByteCount

type MaxStreamDataFrame

+ MaximumStreamData protocol.ByteCount

+ type MaxStreamsFrame struct

+ MaxStreamNum protocol.StreamNum

+ Type protocol.StreamType

+ func (f *MaxStreamsFrame) Length(protocol.VersionNumber) protocol.ByteCount

+ func (f *MaxStreamsFrame) Write(b *bytes.Buffer, _ protocol.VersionNumber) error

+ type NewConnectionIDFrame struct

+ ConnectionID protocol.ConnectionID

+ RetirePriorTo uint64

+ SequenceNumber uint64

+ StatelessResetToken protocol.StatelessResetToken

+ func (f *NewConnectionIDFrame) Length(protocol.VersionNumber) protocol.ByteCount

+ func (f *NewConnectionIDFrame) Write(b *bytes.Buffer, _ protocol.VersionNumber) error

+ type NewTokenFrame struct

+ Token []byte

+ func (f *NewTokenFrame) Length(protocol.VersionNumber) protocol.ByteCount

+ func (f *NewTokenFrame) Write(b *bytes.Buffer, _ protocol.VersionNumber) error

+ type PreferredAddress struct

+ ConnectionID protocol.ConnectionID

+ IPv4 net.IP

+ IPv4Port uint16

+ IPv6 net.IP

+ IPv6Port uint16

+ StatelessResetToken protocol.StatelessResetToken

+ type ResetStreamFrame struct

+ ErrorCode protocol.ApplicationErrorCode

+ FinalSize protocol.ByteCount

+ StreamID protocol.StreamID

+ func (f *ResetStreamFrame) Length(version protocol.VersionNumber) protocol.ByteCount

+ func (f *ResetStreamFrame) Write(b *bytes.Buffer, _ protocol.VersionNumber) error

+ type RetireConnectionIDFrame struct

+ SequenceNumber uint64

+ func (f *RetireConnectionIDFrame) Length(protocol.VersionNumber) protocol.ByteCount

+ func (f *RetireConnectionIDFrame) Write(b *bytes.Buffer, _ protocol.VersionNumber) error

+ type StreamDataBlockedFrame struct

+ MaximumStreamData protocol.ByteCount

+ StreamID protocol.StreamID

+ func (f *StreamDataBlockedFrame) Length(version protocol.VersionNumber) protocol.ByteCount

+ func (f *StreamDataBlockedFrame) Write(b *bytes.Buffer, version protocol.VersionNumber) error

type StreamFrame

+ Fin bool

+ func GetStreamFrame() *StreamFrame

+ func (f *StreamFrame) PutBack()

+ type StreamsBlockedFrame struct

+ StreamLimit protocol.StreamNum

+ Type protocol.StreamType

+ func (f *StreamsBlockedFrame) Length(_ protocol.VersionNumber) protocol.ByteCount

+ func (f *StreamsBlockedFrame) Write(b *bytes.Buffer, _ protocol.VersionNumber) error

+ type TransportParameters struct

+ AckDelayExponent uint8

+ ActiveConnectionIDLimit uint64

+ DisableActiveMigration bool

+ InitialMaxData protocol.ByteCount

+ InitialMaxStreamDataBidiLocal protocol.ByteCount

+ InitialMaxStreamDataBidiRemote protocol.ByteCount

+ InitialMaxStreamDataUni protocol.ByteCount

+ InitialSourceConnectionID protocol.ConnectionID

+ MaxAckDelay time.Duration

+ MaxBidiStreamNum protocol.StreamNum

+ MaxDatagramFrameSize protocol.ByteCount

+ MaxIdleTimeout time.Duration

+ MaxUDPPayloadSize protocol.ByteCount

+ MaxUniStreamNum protocol.StreamNum

+ OriginalDestinationConnectionID protocol.ConnectionID

+ PreferredAddress *PreferredAddress

+ RetrySourceConnectionID *protocol.ConnectionID

+ StatelessResetToken *protocol.StatelessResetToken

+ func (p *TransportParameters) Marshal(pers protocol.Perspective) []byte

+ func (p *TransportParameters) MarshalForSessionTicket(b *bytes.Buffer)

+ func (p *TransportParameters) String() string

+ func (p *TransportParameters) Unmarshal(data []byte, sentBy protocol.Perspective) error

+ func (p *TransportParameters) UnmarshalFromSessionTicket(r *bytes.Reader) error

+ func (p *TransportParameters) ValidFor0RTT(saved *TransportParameters) bool

v0.10.1

Jan 17, 2019

v0.10.1-no-integrationtests

Jan 17, 2019

v0.10.0

Aug 28, 2018

v0.10.0-no-integrationtests

Aug 31, 2018

v0.9.0

Aug 16, 2018

Changes in this version

type Header

+ OrigDestConnectionID protocol.ConnectionID

+ Token []byte

+ type InvariantHeader struct

+ DestConnectionID protocol.ConnectionID

+ IsLongHeader bool

+ SrcConnectionID protocol.ConnectionID

+ Version protocol.VersionNumber

+ func ParseInvariantHeader(b *bytes.Reader, shortHeaderConnIDLen int) (*InvariantHeader, error)

+ func (iv *InvariantHeader) Parse(b *bytes.Reader, sentBy protocol.Perspective, ver protocol.VersionNumber) (*Header, error)

v0.8.0

Jun 27, 2018

Changes in this version

type AckFrame

+ func (f *AckFrame) Length(version protocol.VersionNumber) protocol.ByteCount

type AckRange

+ Largest protocol.PacketNumber

+ Smallest protocol.PacketNumber

+ func (r AckRange) Len() protocol.PacketNumber

type BlockedFrame

+ func (f *BlockedFrame) Length(version protocol.VersionNumber) protocol.ByteCount

type ConnectionCloseFrame

+ func (f *ConnectionCloseFrame) Length(version protocol.VersionNumber) protocol.ByteCount

type Frame

+ func ParseNextFrame(r *bytes.Reader, hdr *Header, v protocol.VersionNumber) (Frame, error)

+ Length func(version protocol.VersionNumber) protocol.ByteCount

type GoawayFrame

+ func (f *GoawayFrame) Length(version protocol.VersionNumber) protocol.ByteCount

type Header

+ DestConnectionID protocol.ConnectionID

+ IsPublicHeader bool

+ PayloadLen protocol.ByteCount

+ SrcConnectionID protocol.ConnectionID

type MaxDataFrame

+ func (f *MaxDataFrame) Length(version protocol.VersionNumber) protocol.ByteCount

type MaxStreamDataFrame

+ func (f *MaxStreamDataFrame) Length(version protocol.VersionNumber) protocol.ByteCount

type MaxStreamIDFrame

+ func (f *MaxStreamIDFrame) Length(protocol.VersionNumber) protocol.ByteCount

+ type PathChallengeFrame struct

+ Data [8]byte

+ func (f *PathChallengeFrame) Length(_ protocol.VersionNumber) protocol.ByteCount

+ func (f *PathChallengeFrame) Write(b *bytes.Buffer, _ protocol.VersionNumber) error

+ type PathResponseFrame struct

+ Data [8]byte

+ func (f *PathResponseFrame) Length(_ protocol.VersionNumber) protocol.ByteCount

+ func (f *PathResponseFrame) Write(b *bytes.Buffer, _ protocol.VersionNumber) error

type PingFrame

+ func (f *PingFrame) Length(version protocol.VersionNumber) protocol.ByteCount

type RstStreamFrame

+ func (f *RstStreamFrame) Length(version protocol.VersionNumber) protocol.ByteCount

type StopSendingFrame

+ func (f *StopSendingFrame) Length(_ protocol.VersionNumber) protocol.ByteCount

type StopWaitingFrame

+ func (f *StopWaitingFrame) Length(_ protocol.VersionNumber) protocol.ByteCount

type StreamBlockedFrame

+ func (f *StreamBlockedFrame) Length(version protocol.VersionNumber) protocol.ByteCount

type StreamFrame

+ func (f *StreamFrame) Length(version protocol.VersionNumber) protocol.ByteCount

+ func (f *StreamFrame) MaxDataLen(maxSize protocol.ByteCount, version protocol.VersionNumber) protocol.ByteCount

+ func (f *StreamFrame) MaybeSplitOffFrame(maxSize protocol.ByteCount, version protocol.VersionNumber) (*StreamFrame, error)

type StreamIDBlockedFrame

+ func (f *StreamIDBlockedFrame) Length(_ protocol.VersionNumber) protocol.ByteCount

v0.7.0

Feb 3, 2018

Changes in this version

type BlockedFrame

+ Offset protocol.ByteCount

+ type MaxStreamIDFrame struct

+ StreamID protocol.StreamID

+ func ParseMaxStreamIDFrame(r *bytes.Reader, _ protocol.VersionNumber) (*MaxStreamIDFrame, error)

+ func (f *MaxStreamIDFrame) MinLength(protocol.VersionNumber) protocol.ByteCount

+ func (f *MaxStreamIDFrame) Write(b *bytes.Buffer, _ protocol.VersionNumber) error

+ type StopSendingFrame struct

+ ErrorCode protocol.ApplicationErrorCode

+ StreamID protocol.StreamID

+ func ParseStopSendingFrame(r *bytes.Reader, _ protocol.VersionNumber) (*StopSendingFrame, error)

+ func (f *StopSendingFrame) MinLength(_ protocol.VersionNumber) protocol.ByteCount

+ func (f *StopSendingFrame) Write(b *bytes.Buffer, _ protocol.VersionNumber) error

type StreamBlockedFrame

+ Offset protocol.ByteCount

+ type StreamIDBlockedFrame struct

+ StreamID protocol.StreamID

+ func ParseStreamIDBlockedFrame(r *bytes.Reader, _ protocol.VersionNumber) (*StreamIDBlockedFrame, error)

+ func (f *StreamIDBlockedFrame) MinLength(_ protocol.VersionNumber) protocol.ByteCount

+ func (f *StreamIDBlockedFrame) Write(b *bytes.Buffer, _ protocol.VersionNumber) error

v0.6.0

Dec 12, 2017

Changes in this version

+ func ComposeGQUICVersionNegotiation(connID protocol.ConnectionID, versions []protocol.VersionNumber) []byte

+ func ComposeVersionNegotiation(connID protocol.ConnectionID, pn protocol.PacketNumber, ...) []byte

+ func LogFrame(frame Frame, sent bool)

+ func WritePublicReset(connectionID protocol.ConnectionID, rejectedPacketNumber protocol.PacketNumber, ...) []byte

+ type AckFrame struct

+ AckRanges []AckRange

+ DelayTime time.Duration

+ LargestAcked protocol.PacketNumber

+ LowestAcked protocol.PacketNumber

+ PacketReceivedTime time.Time

+ func ParseAckFrame(r *bytes.Reader, version protocol.VersionNumber) (*AckFrame, error)

+ func (f *AckFrame) AcksPacket(p protocol.PacketNumber) bool

+ func (f *AckFrame) HasMissingRanges() bool

+ func (f *AckFrame) MinLength(version protocol.VersionNumber) (protocol.ByteCount, error)

+ func (f *AckFrame) Write(b *bytes.Buffer, version protocol.VersionNumber) error

+ type AckRange struct

+ First protocol.PacketNumber

+ Last protocol.PacketNumber

+ type BlockedFrame struct

+ func ParseBlockedFrame(r *bytes.Reader, version protocol.VersionNumber) (*BlockedFrame, error)

+ func (f *BlockedFrame) MinLength(version protocol.VersionNumber) (protocol.ByteCount, error)

+ func (f *BlockedFrame) Write(b *bytes.Buffer, version protocol.VersionNumber) error

+ type ConnectionCloseFrame struct

+ ErrorCode qerr.ErrorCode

+ ReasonPhrase string

+ func ParseConnectionCloseFrame(r *bytes.Reader, version protocol.VersionNumber) (*ConnectionCloseFrame, error)

+ func (f *ConnectionCloseFrame) MinLength(version protocol.VersionNumber) (protocol.ByteCount, error)

+ func (f *ConnectionCloseFrame) Write(b *bytes.Buffer, version protocol.VersionNumber) error

+ type Frame interface

+ MinLength func(version protocol.VersionNumber) (protocol.ByteCount, error)

+ Write func(b *bytes.Buffer, version protocol.VersionNumber) error

+ func ParseBlockedFrameLegacy(r *bytes.Reader, _ protocol.VersionNumber) (Frame, error)

+ func ParseWindowUpdateFrame(r *bytes.Reader, _ protocol.VersionNumber) (Frame, error)

+ type GoawayFrame struct

+ ErrorCode qerr.ErrorCode

+ LastGoodStream protocol.StreamID

+ ReasonPhrase string

+ func ParseGoawayFrame(r *bytes.Reader, _ protocol.VersionNumber) (*GoawayFrame, error)

+ func (f *GoawayFrame) MinLength(version protocol.VersionNumber) (protocol.ByteCount, error)

+ func (f *GoawayFrame) Write(b *bytes.Buffer, _ protocol.VersionNumber) error

+ type Header struct

+ ConnectionID protocol.ConnectionID

+ DiversificationNonce []byte

+ IsLongHeader bool

+ IsVersionNegotiation bool

+ KeyPhase int

+ OmitConnectionID bool

+ PacketNumber protocol.PacketNumber

+ PacketNumberLen protocol.PacketNumberLen

+ Raw []byte

+ ResetFlag bool

+ SupportedVersions []protocol.VersionNumber

+ Type protocol.PacketType

+ Version protocol.VersionNumber

+ VersionFlag bool

+ func ParseHeaderSentByClient(b *bytes.Reader) (*Header, error)

+ func ParseHeaderSentByServer(b *bytes.Reader, version protocol.VersionNumber) (*Header, error)

+ func (h *Header) GetLength(pers protocol.Perspective, version protocol.VersionNumber) (protocol.ByteCount, error)

+ func (h *Header) Log()

+ func (h *Header) Write(b *bytes.Buffer, pers protocol.Perspective, version protocol.VersionNumber) error

+ type MaxDataFrame struct

+ ByteOffset protocol.ByteCount

+ func ParseMaxDataFrame(r *bytes.Reader, version protocol.VersionNumber) (*MaxDataFrame, error)

+ func (f *MaxDataFrame) MinLength(version protocol.VersionNumber) (protocol.ByteCount, error)

+ func (f *MaxDataFrame) Write(b *bytes.Buffer, version protocol.VersionNumber) error

+ type MaxStreamDataFrame struct

+ ByteOffset protocol.ByteCount

+ StreamID protocol.StreamID

+ func ParseMaxStreamDataFrame(r *bytes.Reader, version protocol.VersionNumber) (*MaxStreamDataFrame, error)

+ func (f *MaxStreamDataFrame) MinLength(version protocol.VersionNumber) (protocol.ByteCount, error)

+ func (f *MaxStreamDataFrame) Write(b *bytes.Buffer, version protocol.VersionNumber) error

+ type PingFrame struct

+ func ParsePingFrame(r *bytes.Reader, version protocol.VersionNumber) (*PingFrame, error)

+ func (f *PingFrame) MinLength(version protocol.VersionNumber) (protocol.ByteCount, error)

+ func (f *PingFrame) Write(b *bytes.Buffer, version protocol.VersionNumber) error

+ type PublicReset struct

+ Nonce uint64

+ RejectedPacketNumber protocol.PacketNumber

+ func ParsePublicReset(r *bytes.Reader) (*PublicReset, error)

+ type RstStreamFrame struct

+ ByteOffset protocol.ByteCount

+ ErrorCode uint32

+ StreamID protocol.StreamID

+ func ParseRstStreamFrame(r *bytes.Reader, version protocol.VersionNumber) (*RstStreamFrame, error)

+ func (f *RstStreamFrame) MinLength(version protocol.VersionNumber) (protocol.ByteCount, error)

+ func (f *RstStreamFrame) Write(b *bytes.Buffer, version protocol.VersionNumber) error

+ type StopWaitingFrame struct

+ LeastUnacked protocol.PacketNumber

+ PacketNumber protocol.PacketNumber

+ PacketNumberLen protocol.PacketNumberLen

+ func ParseStopWaitingFrame(r *bytes.Reader, packetNumber protocol.PacketNumber, ...) (*StopWaitingFrame, error)

+ func (f *StopWaitingFrame) MinLength(_ protocol.VersionNumber) (protocol.ByteCount, error)

+ func (f *StopWaitingFrame) Write(b *bytes.Buffer, _ protocol.VersionNumber) error

+ type StreamBlockedFrame struct

+ StreamID protocol.StreamID

+ func ParseStreamBlockedFrame(r *bytes.Reader, version protocol.VersionNumber) (*StreamBlockedFrame, error)

+ func (f *StreamBlockedFrame) MinLength(version protocol.VersionNumber) (protocol.ByteCount, error)

+ func (f *StreamBlockedFrame) Write(b *bytes.Buffer, version protocol.VersionNumber) error

+ type StreamFrame struct

+ Data []byte

+ DataLenPresent bool

+ FinBit bool

+ Offset protocol.ByteCount

+ StreamID protocol.StreamID

+ func ParseStreamFrame(r *bytes.Reader, version protocol.VersionNumber) (*StreamFrame, error)

+ func (f *StreamFrame) DataLen() protocol.ByteCount

+ func (f *StreamFrame) MinLength(version protocol.VersionNumber) (protocol.ByteCount, error)

+ func (f *StreamFrame) Write(b *bytes.Buffer, version protocol.VersionNumber) error

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