wire

Documentation

Index

• Constants
• Variables
• func GetRequestId() []byte
• func WritePacket(stream network.Stream, packet *Packet) error
• type Packet
  • func ReadPacket(stream network.Stream) (*Packet, error)
  • func (p *Packet) String() string
• type PacketType

Constants

const FragmentSize = 1024 * 512

Variables

var (
	PtypeMap = map[PacketType]string{
		PTypeSendHeader: "SendHeader",
		PtypeSendBody:   "SendBody",
		PtypeEndBody:    "EndBody",
		PtypeReSendBody: "ReSendBody",
	}
)

Functions

func GetRequestId

func GetRequestId() []byte

func WritePacket

func WritePacket(stream network.Stream, packet *Packet) error

Types

type Packet

type Packet struct {
	PType  PacketType
	Offset int32 // current offset
	Total  int32 // total body size
	Data   []byte
}

func ReadPacket

func ReadPacket(stream network.Stream) (*Packet, error)

func (*Packet) String

func (p *Packet) String() string

type PacketType

type PacketType = uint8

const (
	PTypeSendHeader PacketType = iota
	PtypeSendBody   PacketType = iota
	PtypeEndBody    PacketType = iota
	PtypeReSendBody PacketType = iota
)