wire

package

Go to main page

Versions in this module

v0

v0.29.102

Oct 16, 2022

Changes in this version

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

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

+ func Is0RTTPacket(b []byte) bool

+ func IsLongHeaderPacket(firstByte byte) bool

+ func IsVersionNegotiationPacket(b []byte) bool

+ func LogShortHeader(logger utils.Logger, dest protocol.ConnectionID, pn protocol.PacketNumber, ...)

+ func ParseArbitraryLenConnectionIDs(data []byte) (bytesParsed int, dest, src protocol.ArbitraryLenConnectionID, _ error)

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

+ func ParseShortHeader(data []byte, connIDLen int) (length int, _ protocol.PacketNumber, _ protocol.PacketNumberLen, ...)

+ func ParseVersion(data []byte) (protocol.VersionNumber, error)

+ func ParseVersionNegotiationPacket(b []byte) (dest, src protocol.ArbitraryLenConnectionID, _ []protocol.VersionNumber, ...)

+ func PutAckFrame(f *AckFrame)

type AckFrame

+ ECNCE uint64

+ ECT0 uint64

+ ECT1 uint64

+ func GetAckFrame() *AckFrame

+ func (f *AckFrame) Append(b []byte, _ protocol.VersionNumber) ([]byte, error)

type ConnectionCloseFrame

+ FrameType uint64

+ IsApplicationError bool

+ func (f *ConnectionCloseFrame) Append(b []byte, _ protocol.VersionNumber) ([]byte, error)

+ type CryptoFrame struct

+ Data []byte

+ Offset protocol.ByteCount

+ func (f *CryptoFrame) Append(b []byte, _ protocol.VersionNumber) ([]byte, error)

+ 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)

+ type DataBlockedFrame struct

+ MaximumData protocol.ByteCount

+ func (f *DataBlockedFrame) Append(b []byte, version protocol.VersionNumber) ([]byte, error)

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

+ type DatagramFrame struct

+ Data []byte

+ DataLenPresent bool

+ func (f *DatagramFrame) Append(b []byte, _ protocol.VersionNumber) ([]byte, error)

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

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

+ 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 Frame

+ Append func(b []byte, version protocol.VersionNumber) ([]byte, error)

+ type FrameParser interface

+ ParseNext func([]byte, protocol.EncryptionLevel) (int, Frame, error)

+ SetAckDelayExponent func(uint8)

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

+ type HandshakeDoneFrame struct

+ func (f *HandshakeDoneFrame) Append(b []byte, _ protocol.VersionNumber) ([]byte, error)

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

type Header

+ Length protocol.ByteCount

+ func ParsePacket(data []byte, shortHeaderConnIDLen int) (*Header, []byte, []byte, 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

+ func (f *MaxDataFrame) Append(b []byte, _ protocol.VersionNumber) ([]byte, error)

type MaxStreamDataFrame

+ MaximumStreamData protocol.ByteCount

+ func (f *MaxStreamDataFrame) Append(b []byte, version protocol.VersionNumber) ([]byte, error)

+ type MaxStreamsFrame struct

+ MaxStreamNum protocol.StreamNum

+ Type protocol.StreamType

+ func (f *MaxStreamsFrame) Append(b []byte, _ protocol.VersionNumber) ([]byte, error)

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

+ type NewConnectionIDFrame struct

+ ConnectionID protocol.ConnectionID

+ RetirePriorTo uint64

+ SequenceNumber uint64

+ StatelessResetToken protocol.StatelessResetToken

+ func (f *NewConnectionIDFrame) Append(b []byte, _ protocol.VersionNumber) ([]byte, error)

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

+ type NewTokenFrame struct

+ Token []byte

+ func (f *NewTokenFrame) Append(b []byte, _ protocol.VersionNumber) ([]byte, error)

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

type PathChallengeFrame

+ func (f *PathChallengeFrame) Append(b []byte, _ protocol.VersionNumber) ([]byte, error)

type PathResponseFrame

+ func (f *PathResponseFrame) Append(b []byte, _ protocol.VersionNumber) ([]byte, error)

type PingFrame

+ func (f *PingFrame) Append(b []byte, _ protocol.VersionNumber) ([]byte, error)

+ type PreferredAddress struct

+ ConnectionID protocol.ConnectionID

+ IPv4 net.IP

+ IPv4Port uint16

+ IPv6 net.IP

+ IPv6Port uint16

+ StatelessResetToken protocol.StatelessResetToken

+ type ResetStreamFrame struct

+ ErrorCode qerr.StreamErrorCode

+ FinalSize protocol.ByteCount

+ StreamID protocol.StreamID

+ func (f *ResetStreamFrame) Append(b []byte, _ protocol.VersionNumber) ([]byte, error)

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

+ type RetireConnectionIDFrame struct

+ SequenceNumber uint64

+ func (f *RetireConnectionIDFrame) Append(b []byte, _ protocol.VersionNumber) ([]byte, error)

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

type StopSendingFrame

+ func (f *StopSendingFrame) Append(b []byte, _ protocol.VersionNumber) ([]byte, error)

+ type StreamDataBlockedFrame struct

+ MaximumStreamData protocol.ByteCount

+ StreamID protocol.StreamID

+ func (f *StreamDataBlockedFrame) Append(b []byte, _ protocol.VersionNumber) ([]byte, error)

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

type StreamFrame

+ Fin bool

+ func GetStreamFrame() *StreamFrame

+ func (f *StreamFrame) Append(b []byte, _ protocol.VersionNumber) ([]byte, error)

+ func (f *StreamFrame) PutBack()

+ type StreamsBlockedFrame struct

+ StreamLimit protocol.StreamNum

+ Type protocol.StreamType

+ func (f *StreamsBlockedFrame) Append(b []byte, _ protocol.VersionNumber) ([]byte, error)

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

+ 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 []byte) []byte

+ 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