codec

Jan 13, 2019

Changes in this version

+ type Marshaler interface

+ Marshal func(interface{}) ([]byte, error)

+ String func() string

+ Unmarshal func([]byte, interface{}) error

type Message

+ Body []byte

+ Endpoint string

+ type Reader interface

+ ReadBody func(interface{}) error

+ ReadHeader func(*Message, MessageType) error

+ type Writer interface

+ Write func(*Message, interface{}) error

Jun 11, 2017

Changes in this version

+ type Codec interface

+ Close func() error

+ ReadBody func(interface{}) error

+ ReadHeader func(*Message, MessageType) error

+ String func() string

+ Write func(*Message, interface{}) error

+ type Message struct

+ Error string

+ Header map[string]string

+ Id uint64

+ Method string

+ Target string

+ Type MessageType

+ type MessageType int

+ const Error

+ const Publication

+ const Request

+ const Response

+ type NewCodec func(io.ReadWriteCloser) Codec