Documentation
¶
Index ¶
- func GobGeneralDecoder() func([]byte, interface{})
- func JsonGeneralDecoder() func([]byte, interface{})
- func JsonGeneralEncoder() func(interface{}) ([]byte, error)
- func NewGobDecodeRop(gen interface{}) stream.InOutOperator
- func NewGobEncodeRop() stream.InOutOperator
- func NewJsonDecodeRop(gen interface{}) stream.Operator
- func NewJsonEncodeRop() stream.Operator
- func NewMakeProtobufMessageOp() stream.Operator
- func NewProtobufDecodeOp(gen interface{}) stream.Operator
- func NewProtobufEncodeOp() stream.Operator
- func ProtobufGeneralDecoder() func([]byte, proto.Message)
- type ByteReader
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GobGeneralDecoder ¶
func GobGeneralDecoder() func([]byte, interface{})
func JsonGeneralDecoder ¶
func JsonGeneralDecoder() func([]byte, interface{})
func JsonGeneralEncoder ¶
func NewGobDecodeRop ¶
func NewGobDecodeRop(gen interface{}) stream.InOutOperator
func NewGobEncodeRop ¶
func NewGobEncodeRop() stream.InOutOperator
func NewJsonDecodeRop ¶
func NewJsonEncodeRop ¶
func NewProtobufDecodeOp ¶
func NewProtobufEncodeOp ¶
func ProtobufGeneralDecoder ¶
Types ¶
type ByteReader ¶
type ByteReader struct {
// contains filtered or unexported fields
}
stolen from bytes.Reader. Slightly changed to allow us to reuse gob.Decoder on same object
Source Files
Click to show internal directories.
Click to hide internal directories.