encoding

Documentation

Index

• func GobGeneralDecoder() func([]byte, interface{})
• func JsonGeneralDecoder() func([]byte, interface{})
• func JsonGeneralEncoder() func(interface{}) ([]byte, error)
• func NewGobDecodeOp(decFn func([]byte, func([]byte, interface{})) stream.Object) stream.InOutOperator
• func NewGobEncodeOp() stream.InOutOperator
• func NewJsonDecodeOp(decFn func([]byte, func([]byte, interface{})) stream.Object) stream.InOutOperator
• func NewJsonEncodeOp() stream.Operator
• func NewProtobufDecodeOp(decFn func([]byte, func([]byte, proto.Message)) stream.Object) stream.InOutOperator
• func NewProtobufEncodeOp() stream.Operator
• func ProtobufGeneralDecoder() func([]byte, proto.Message)
• type ByteReader
  • func (r *ByteReader) Read(b []byte) (n int, err error)

Functions

func GobGeneralDecoder

func GobGeneralDecoder() func([]byte, interface{})

func JsonGeneralDecoder

func JsonGeneralDecoder() func([]byte, interface{})

func JsonGeneralEncoder

func JsonGeneralEncoder() func(interface{}) ([]byte, error)

func NewGobDecodeOp

func NewGobDecodeOp(
	decFn func([]byte, func([]byte, interface{})) stream.Object) stream.InOutOperator

func NewGobEncodeOp

func NewGobEncodeOp() stream.InOutOperator

func NewJsonDecodeOp

func NewJsonDecodeOp(decFn func([]byte, func([]byte, interface{})) stream.Object) stream.InOutOperator

func NewJsonEncodeOp

func NewJsonEncodeOp() stream.Operator

func NewProtobufDecodeOp

func NewProtobufDecodeOp(decFn func([]byte, func([]byte, proto.Message)) stream.Object) stream.InOutOperator

func NewProtobufEncodeOp

func NewProtobufEncodeOp() stream.Operator

func ProtobufGeneralDecoder

func ProtobufGeneralDecoder() func([]byte, proto.Message)

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

func (*ByteReader) Read

func (r *ByteReader) Read(b []byte) (n int, err error)