Versions in this module Expand all Collapse all v4 v4.0.4 Feb 13, 2023 v4.0.3 Oct 11, 2021 Changes in this version + const ServiceError + var ErrMessageToLong = errors.New("message is too long") + var ErrMetaKVMissing = errors.New("wrong metadata lines. some keys or values are missing") + var MaxMessageLength = 0 + func FreeMsg(msg *Message) + type CompressType byte + const Gzip + const None + type Header [12]byte + func (h *Header) SetCompressType(ct CompressType) + func (h *Header) SetHeartbeat(hb bool) + func (h *Header) SetMessageStatusType(mt MessageStatusType) + func (h *Header) SetMessageType(mt MessageType) + func (h *Header) SetOneway(oneway bool) + func (h *Header) SetSeq(seq uint64) + func (h *Header) SetSerializeType(st SerializeType) + func (h *Header) SetVersion(v byte) + func (h Header) CheckMagicNumber() bool + func (h Header) CompressType() CompressType + func (h Header) IsHeartbeat() bool + func (h Header) IsOneway() bool + func (h Header) MessageStatusType() MessageStatusType + func (h Header) MessageType() MessageType + func (h Header) Seq() uint64 + func (h Header) SerializeType() SerializeType + func (h Header) Version() byte + type Message struct + Metadata map[string]string + Payload []byte + ServiceMethod string + ServicePath string + func GetPooledMsg() *Message + func NewMessage() *Message + func Read(r io.Reader) (*Message, error) + func (m *Message) Decode(r io.Reader) error + func (m *Message) Reset() + func (m Message) Clone() *Message + func (m Message) Encode() []byte + func (m Message) WriteTo(w io.Writer) error + type MessageStatusType byte + const Error + const Normal + type MessageType byte + const Request + const Response + type SerializeType byte + const JSON + const MsgPack + const ProtoBuffer + const SerializeNone Other modules containing this package github.com/werunclub/rpcx
Go to main page