fragmentation

Documentation

Index

• Constants
• func IsValidFragment(fragment int) (err error)
• func Split(mtu int, data []byte, metadata []byte, ...)
• func SplitSkip(mtu int, skip int, data []byte, metadata []byte, ...)
• type HeaderAndPayload
• type Joiner
  • func NewJoiner(first HeaderAndPayload) Joiner

Constants

const (
	// MinFragment is minimum fragment size in bytes.
	MinFragment = framing.HeaderLen + 4
	// MaxFragment is minimum fragment size in bytes.
	MaxFragment = common.MaxUint24 - 3
)

Functions

func IsValidFragment

func IsValidFragment(fragment int) (err error)

IsValidFragment validate fragment size.

func Split

func Split(mtu int, data []byte, metadata []byte, onFrame func(idx int, fg framing.FrameFlag, body *common.ByteBuff))

Split split data and metadata in frame.

func SplitSkip

func SplitSkip(mtu int, skip int, data []byte, metadata []byte, onFrame func(idx int, fg framing.FrameFlag, body *common.ByteBuff))

SplitSkip skip some bytes and split data and metadata in frame.

Types

type HeaderAndPayload

type HeaderAndPayload interface {
	payload.Payload
	// Header returns a header of frame.
	Header() framing.FrameHeader
}

HeaderAndPayload is Payload which having a FrameHeader.

type Joiner

type Joiner interface {
	HeaderAndPayload
	// First returns the first frame.
	First() framing.Frame
	// Push append a new frame and returns true if joiner is end.
	Push(elem HeaderAndPayload) (end bool)
}

Joiner is used to join frames to a payload.

func NewJoiner

func NewJoiner(first HeaderAndPayload) Joiner

NewJoiner returns a new joiner.