Versions in this module Expand all Collapse all v0 v0.9.0 Apr 11, 2023 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
Go to main page