type Reader …
type Writer …
type Framer …
func RawFramer() Framer { … }
type rawFramer …
type rawReader …
type rawWriter …
func (rawFramer) Reader(rw io.Reader) Reader { … }
func (rawFramer) Writer(rw io.Writer) Writer { … }
func (r *rawReader) Read(ctx context.Context) (Message, int64, error) { … }
func (w *rawWriter) Write(ctx context.Context, msg Message) (int64, error) { … }
func HeaderFramer() Framer { … }
type headerFramer …
type headerReader …
type headerWriter …
func (headerFramer) Reader(rw io.Reader) Reader { … }
func (headerFramer) Writer(rw io.Writer) Writer { … }
func (r *headerReader) Read(ctx context.Context) (Message, int64, error) { … }
func (w *headerWriter) Write(ctx context.Context, msg Message) (int64, error) { … }