readwriter

Documentation

Index

• Constants
• Variables
• type RpcPackageHandler
  • func (p *RpcPackageHandler) Read(ss getty.Session, data []byte) (interface{}, int, error)
  • func (p *RpcPackageHandler) Write(ss getty.Session, pkg interface{}) ([]byte, error)
• type SeataV1PackageHeader
  • func (h *SeataV1PackageHeader) Unmarshal(buf *bytes.Buffer) (int, error)

Constants

const (
	SeataV1PackageHeaderReservedLength = 16
)

*

• <pre>
• 0 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
• +-----+-----+-----+-----+-----+-----+-----+-----+-----+-----+-----+-----+-----+-----+-----+-----+
• | magic |Proto| Full length | Head | Msg |Seria|Compr| RequestID |
• | code |colVer| (head+body) | Length |Type |lizer|ess | |
• +-----------+-----------+-----------+-----------+-----------+-----------+-----------+-----------+
• | |
• | Head Map [Optional] |
• +-----------+-----------+-----------+-----------+-----------+-----------+-----------+-----------+
• | |
• | body |
• | |
• | ... ... |
• +-----------------------------------------------------------------------------------------------+
• </pre>
• <p>
• <li>Full Length: include all data </li>
• <li>Head Length: include head data from magic code to head map. </li>
• <li>Body Length: Full Length - Head Length</li>
• </p>
• https://github.com/seata/seata/issues/893

Variables

var (
	ErrNotEnoughStream = errors.New("packet stream is not enough")
	ErrTooLargePackage = errors.New("package length is exceed the getty package's legal maximum length.")
	ErrInvalidPackage  = errors.New("invalid rpc package")
	ErrIllegalMagic    = errors.New("package magic is not right.")
)

var (
	// RpcPkgHandler
	RpcPkgHandler = &RpcPackageHandler{}
)

Types

type RpcPackageHandler

type RpcPackageHandler struct{}

func (*RpcPackageHandler) Read

func (p *RpcPackageHandler) Read(ss getty.Session, data []byte) (interface{}, int, error)

Read read binary data from to rpc message

func (*RpcPackageHandler) Write

func (p *RpcPackageHandler) Write(ss getty.Session, pkg interface{}) ([]byte, error)

Write write rpc message to binary data

type SeataV1PackageHeader

type SeataV1PackageHeader struct {
	Magic0       byte
	Magic1       byte
	Version      byte
	TotalLength  uint32
	HeadLength   uint16
	MessageType  byte
	CodecType    byte
	CompressType byte
	ID           uint32
	Meta         map[string]string
	BodyLength   uint32
}

func (*SeataV1PackageHeader) Unmarshal

func (h *SeataV1PackageHeader) Unmarshal(buf *bytes.Buffer) (int, error)