frame

package

Go to main page

Versions in this module

v0

v0.0.4

Dec 4, 2024

v0.0.3

Dec 3, 2024

Changes in this version

+ const IDMTURequest

+ const IDMTUResponse

type Acknowledgement

+ Max uint32

type AcknowledgementRange

+ func GenerateAcknowledgementRanges(list []uint32) (ranges []AcknowledgementRange)

type ConnectionClose

+ func (fr *ConnectionClose) Reset()

type ConnectionRequest

+ func (fr *ConnectionRequest) Reset()

type ConnectionResponse

+ func (fr *ConnectionResponse) Reset()

type Frame

+ Reset func()

+ type MTURequest struct

+ MTU uint64

+ func (fr *MTURequest) Decode(p []byte) (int, error)

+ func (fr *MTURequest) Encode() []byte

+ func (fr *MTURequest) ID() uint32

+ func (fr *MTURequest) Reset()

+ type MTUResponse struct

+ MTU uint64

+ func (fr *MTUResponse) Decode(p []byte) (int, error)

+ func (fr *MTUResponse) Encode() []byte

+ func (fr *MTUResponse) ID() uint32

+ func (fr *MTUResponse) Reset()

type StreamClose

+ func (fr *StreamClose) Reset()

type StreamRequest

+ func (fr *StreamRequest) Reset()

type StreamResponse

+ func (fr *StreamResponse) Reset()

v0.0.2

Oct 3, 2024

v0.0.1

Oct 2, 2024

Changes in this version

+ const AcknowledgementWithGaps

+ const AcknowledgementWithoutGaps

+ const ConnectionCloseApplication

+ const ConnectionCloseGraceful

+ const ConnectionCloseInternal

+ const ConnectionCloseTimeout

+ const ConnectionResponseFailed

+ const ConnectionResponseSuccess

+ const IDAcknowledgement

+ const IDConnectionClose

+ const IDConnectionRequest

+ const IDConnectionResponse

+ const IDStreamClose

+ const IDStreamData

+ const IDStreamRequest

+ const IDStreamResponse

+ const StreamResponseFailed

+ const StreamResponseSuccess

+ var Pool = sync.Pool

+ func GenerateAcknowledgementGaps(ranges []AcknowledgementRange) []uint32

+ func Pack(connectionID protocol.ConnectionID, sequenceID uint32, total uint32, ...) []byte

+ func PackSingle(fr Frame) ([]byte, error)

+ func PutFrame(fr Frame)

+ type Acknowledgement struct

+ Delay int64

+ Ranges []AcknowledgementRange

+ Type byte

+ func (fr *Acknowledgement) Decode(p []byte) (int, error)

+ func (fr *Acknowledgement) Encode() ([]byte, error)

+ func (fr *Acknowledgement) ID() uint32

+ func (fr *Acknowledgement) Reset()

+ type AcknowledgementRange [2]uint32

+ func GenerateAcknowledgementRange(list []uint32) (byte, []AcknowledgementRange)

+ type ConnectionClose struct

+ Code byte

+ Message string

+ func (fr *ConnectionClose) Decode(p []byte) (int, error)

+ func (fr *ConnectionClose) Encode() ([]byte, error)

+ func (fr *ConnectionClose) ID() uint32

+ type ConnectionRequest struct

+ func (fr *ConnectionRequest) Decode(_ []byte) (n int, err error)

+ func (fr *ConnectionRequest) Encode() (n []byte, err error)

+ func (fr *ConnectionRequest) ID() uint32

+ type ConnectionResponse struct

+ ConnectionID protocol.ConnectionID

+ Response byte

+ func (fr *ConnectionResponse) Decode(p []byte) (int, error)

+ func (fr *ConnectionResponse) Encode() ([]byte, error)

+ func (fr *ConnectionResponse) ID() uint32

+ type Frame interface

+ Decode func(p []byte) (int, error)

+ Encode func() ([]byte, error)

+ ID func() uint32

+ func GetFrame(id uint32) (Frame, error)

+ func Unpack(p []byte) (connectionID protocol.ConnectionID, sequenceID uint32, frames []Frame, ...)

+ type ResettableFrame interface

+ Reset func()

+ type StreamClose struct

+ StreamID protocol.StreamID

+ func (fr *StreamClose) Decode(p []byte) (int, error)

+ func (fr *StreamClose) Encode() ([]byte, error)

+ func (fr *StreamClose) ID() uint32

+ type StreamData struct

+ Offset uint32

+ Payload []byte

+ SequenceID uint32

+ StreamID protocol.StreamID

+ Total uint32

+ func (fr *StreamData) Decode(p []byte) (int, error)

+ func (fr *StreamData) Encode() ([]byte, error)

+ func (fr *StreamData) ID() uint32

+ func (fr *StreamData) Reset()

+ type StreamRequest struct

+ StreamID protocol.StreamID

+ func (fr *StreamRequest) Decode(p []byte) (int, error)

+ func (fr *StreamRequest) Encode() ([]byte, error)

+ func (fr *StreamRequest) ID() uint32

+ type StreamResponse struct

+ Response byte

+ StreamID protocol.StreamID

+ func (fr *StreamResponse) Decode(p []byte) (int, error)

+ func (fr *StreamResponse) Encode() ([]byte, error)

+ func (fr *StreamResponse) ID() uint32

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