header

Documentation

Index

• Constants
• Variables
• type RequestHeader
  • func (r *RequestHeader) GetCompressType() compressor.CompressType
  • func (r *RequestHeader) Marshal() []byte
  • func (r *RequestHeader) ResetHeader()
  • func (r *RequestHeader) Unmarshal(data []byte) (err error)
• type ResponseHeader
  • func (r *ResponseHeader) GetCompressType() compressor.CompressType
  • func (r *ResponseHeader) Marshal() []byte
  • func (r *ResponseHeader) ResetHeader()
  • func (r *ResponseHeader) Unmarshal(data []byte) (err error)

Constants

const (
	// MaxHeaderSize = 2 + 10 + 10 + 10 + 4 (10 refer to binary.MaxVarintLen64)
	MaxHeaderSize = 36

	Uint16Size = 2
	Uint32Size = 4
)

Variables

var (
	RequestPool  sync.Pool
	ResponsePool sync.Pool
)

var ErrUnmarshal = errors.New("an error occurred in Unmarshal")

Types

type RequestHeader

type RequestHeader struct {
	sync.RWMutex
	CompressType compressor.CompressType
	Method       string
	ID           uint64
	RequestLen   uint32
	Checksum     uint32
}

RequestHeader request header structure looks like: +--------------+----------------+----------+------------+----------+ | CompressType | Method | ID | RequestLen | Checksum | +--------------+----------------+----------+------------+----------+ | uint16 | uvarint+string | uvarint | uvarint | uint32 | +--------------+----------------+----------+------------+----------+

func (*RequestHeader) GetCompressType

func (r *RequestHeader) GetCompressType() compressor.CompressType

GetCompressType get compress type

func (*RequestHeader) Marshal

func (r *RequestHeader) Marshal() []byte

Marshal will encode request header into a byte slice

func (*RequestHeader) ResetHeader

func (r *RequestHeader) ResetHeader()

ResetHeader reset request header

func (*RequestHeader) Unmarshal

func (r *RequestHeader) Unmarshal(data []byte) (err error)

type ResponseHeader

type ResponseHeader struct {
	sync.RWMutex
	CompressType compressor.CompressType
	ID           uint64
	Error        string
	ResponseLen  uint32
	Checksum     uint32
}

ResponseHeader request header structure looks like: +--------------+---------+----------------+-------------+----------+ | CompressType | ID | Error | ResponseLen | Checksum | +--------------+---------+----------------+-------------+----------+ | uint16 | uvarint | uvarint+string | uvarint | uint32 | +--------------+---------+----------------+-------------+----------+

func (*ResponseHeader) GetCompressType

func (r *ResponseHeader) GetCompressType() compressor.CompressType

GetCompressType get compress type

func (*ResponseHeader) Marshal

func (r *ResponseHeader) Marshal() []byte

Marshal will encode response header into a byte slice

func (*ResponseHeader) ResetHeader

func (r *ResponseHeader) ResetHeader()

ResetHeader reset response header

func (*ResponseHeader) Unmarshal

func (r *ResponseHeader) Unmarshal(data []byte) (err error)

Unmarshal will decode response header into a byte slice