packer

package

v1.23.0 Latest Latest Go to latest Published: Mar 12, 2026 License: Apache-2.0 Imports: 4 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/kubeedge/beehive

Links

Open Source Insights

Documentation ¶

Constants ¶

View Source

const (

	// MessageLenOffset message len offset
	MessageLenOffset = magicSize + versionSize + reservedSize
	// MessageOffset message offset
	MessageOffset = MessageLenOffset + 4
	// HeaderLen header len
	HeaderLen = MessageOffset
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Packer ¶

type Packer struct {
	Magic    [magicSize]byte
	Version  [versionSize]byte
	Reserved [reservedSize]byte
	Length   int32
	Message  []byte
}

Packer packer

func NewPacker ¶

func NewPacker() *Packer

NewPacker new packer

func (*Packer) GetMessageLen ¶

func (p *Packer) GetMessageLen(data []byte) int32

GetMessageLen get message len

func (*Packer) Read ¶

func (p *Packer) Read(reader io.Reader) error

Read read

func (*Packer) Validate ¶

func (p *Packer) Validate(data []byte) bool

Validate validate

func (*Packer) Write ¶

func (p *Packer) Write(writer io.Writer) error

Write write

Source Files ¶

View all Source files

packer.go

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