datapackage

Documentation

Index

• type DataPackage
  • func (d *DataPackage) Marshal(buf []byte) ([]byte, error)
  • func (d *DataPackage) Size() (s uint64)
  • func (d *DataPackage) Unmarshal(buf []byte) (uint64, error)
• type Package
  • func NewPackage(protocol string, payload []byte) *Package
  • func (m *Package) FromBytes(data []byte) error
  • func (m *Package) Payload() []byte
  • func (m *Package) Protocol() string
  • func (m *Package) ToBytes(enableCompress bool) ([]byte, error)

Types

type DataPackage

type DataPackage struct {
	Protocol string
	Payload  []byte
	Compress bool
}

DataPackage .

func (*DataPackage) Marshal

func (d *DataPackage) Marshal(buf []byte) ([]byte, error)

Marshal DataPackage.

func (*DataPackage) Size

func (d *DataPackage) Size() (s uint64)

Size DataPackage.

func (*DataPackage) Unmarshal

func (d *DataPackage) Unmarshal(buf []byte) (uint64, error)

Unmarshal DataPackage.

type Package

type Package struct {
	// contains filtered or unexported fields
}

Package is a container for net message.

func NewPackage

func NewPackage(protocol string, payload []byte) *Package

NewPackage create a Package contains message payload with protocol.

func (*Package) FromBytes

func (m *Package) FromBytes(data []byte) error

FromBytes parse bytes received from receive stream into Package.

func (*Package) Payload

func (m *Package) Payload() []byte

Payload return the message payload bytes.

func (*Package) Protocol

func (m *Package) Protocol() string

Protocol return the protocol id that the message marked.

func (*Package) ToBytes

func (m *Package) ToBytes(enableCompress bool) ([]byte, error)

ToBytes parse Package to bytes for sending on stream finally.