framing

type Decoder ¶

type Decoder interface {
	// Decode reads the next encoded message from its input and stores it
	// in the value pointed to by m. If m isn't a proto.Message, Decode will panic.
	Decode(interface{}) error
}

Decoder reads and decodes Protobuf messages from an io.Reader.

type DecoderFunc ¶

type DecoderFunc func(interface{}) error

DecoderFunc is the functional adaptation of Decoder

func NewDecoder(r Reader, uf UnmarshalFunc) DecoderFunc

func (f DecoderFunc) Decode(m interface{}) error

type Error ¶

type Error string

func (err Error) Error() string

type Reader ¶

type Reader interface {
	ReadFrame() (frame []byte, err error)
}

Reader generates data frames from some source, returning io.EOF with the final frame.

type ReaderFunc ¶

type ReaderFunc func() ([]byte, error)

ReaderFunc is the functional adaptation of Reader.

func (f ReaderFunc) ReadFrame() ([]byte, error)

type UnmarshalFunc ¶

type UnmarshalFunc func([]byte, interface{}) error

UnmarshalFunc translates bytes to objects

type Writer ¶

type Writer interface {
	WriteFrame(frame []byte) error
}

Writer sends whole frames to some endpoint; returns io.ErrShortWrite if the frame is only partially written.

type WriterFunc ¶

type WriterFunc func([]byte) error

WriterFunc is the functional adaptation of Writer.

func (f WriterFunc) WriteFrame(b []byte) error