Versions in this module Expand all Collapse all v1 v1.0.1 May 10, 2021 v1.0.0 May 9, 2021 Changes in this version + var ErrInvalidMessage = errors.New("invalid message") + type Codec interface + Close func() error + String func() string + type Marshaler interface + Marshal func(interface{}) ([]byte, error) + String func() string + Unmarshal func([]byte, interface{}) error + type Message struct + Body []byte + Endpoint string + Error string + Header map[string]string + Id string + Method string + Target string + Type MessageType + type MessageType int + const Error + const Event + const Request + const Response + type NewCodec func(io.ReadWriteCloser) Codec + type Reader interface + ReadBody func(interface{}) error + ReadHeader func(*Message, MessageType) error + type Writer interface + Write func(*Message, interface{}) error Incompatible versions in this module v2.3.0+incompatible May 9, 2021
Go to main page