codec

Mar 31, 2025

Changes in this version

+ const PartSize

+ func EncodeReq(writer netpoll.Writer, req *ReqPack) (err error)

+ func PutPayloadCode(name string, v PayloadCodec)

+ func WriteResp(writer netpoll.Writer, msg *RespPack) (err error)

+ func WriteStringToBuf(buffer *bytes.Buffer, b []byte) error

+ type Addr struct

+ Id uint32

+ Name string

+ func GetServiceAddress(address interface{}) (*Addr, error)

+ func (addr *Addr) String() string

+ type PayloadCodec interface

+ IsNull func(in []byte) bool

+ Marshal func(msg any) ([]byte, error)

+ Name func() string

+ Unmarshal func(in []byte, msg any) error

+ func GetPayloadCodec(name string) (PayloadCodec, bool)

+ type ReqPack struct

+ Addr Addr

+ Method string

+ Payload []byte

+ Push bool

+ Session uint32

+ func DecodeReq(pkg netpoll.Reader, pendingPack map[uint32]*ReqPack) (*ReqPack, error)

+ func (req *ReqPack) IsPush() bool

+ type RespPack struct

+ Ok bool

+ Payload []byte

+ Session uint32

+ func ReadResp(pkg netpoll.Reader, pendingResp map[uint32]*RespPack) (resp *RespPack, err error)

+ type RetType byte

+ const RespTypeErr

+ const RespTypeMBegin

+ const RespTypeMEnd

+ const RespTypeMPart

+ const RespTypeOk