Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Codec ¶
type Codec interface { Marshal(v interface{}) ([]byte, error) Unmarshal(bs []byte) (interface{}, error) String() string }
Codec is a simple encoding interface used for the broker/transport where headers are not supported by the underlying implementation.
type JSON ¶
type JSON struct {
// contains filtered or unexported fields
}
func NewJSONCodec ¶
type NewCodec ¶
type NewCodec func() Codec
NewCodec Takes in a connection/buffer and returns a new Codec
type Proto ¶
type Proto struct {
// contains filtered or unexported fields
}
Proto is a Codec for proto/snappy
Click to show internal directories.
Click to hide internal directories.